Package org.apache.iceberg.io

Interface Summary

Interface	Description
CloseableIterable<T>
CloseableIterator<T>
DelegatingInputStream
DelegatingOutputStream
EqualityDeltaWriter<T>	A writer capable of writing data and equality deletes that may belong to different specs and partitions.
FileAppender<D>
FileAppenderFactory<T>	Factory to create a new FileAppender to write records.
FileIO	Pluggable module for reading, writing, and deleting files.
FileWriter<T,R>	A writer capable of writing files of a single type (i.e.
FileWriterFactory<T>	A factory for creating data and delete writers.
InputFile	An interface used to read input files using SeekableInputStream instances.
LocationProvider	Interface for providing data file locations to write tasks.
OutputFile	An interface used to create output files using PositionOutputStream instances.
PartitioningWriter<T,R>	A writer capable of writing files of a single type (i.e.
PositionDeltaWriter<T>	A writer capable of writing data and position deletes that may belong to different specs and partitions.
TaskWriter<T>	The writer interface could accept records and provide the generated data files.

Class Summary

Class	Description
BasePositionDeltaWriter<T>
BaseTaskWriter<T>
CloseableGroup	This class acts as a helper for handling the closure of multiple resource.
CloseableIterable.ConcatCloseableIterable<E>
ClosingIterator<T>	A convenience wrapper around CloseableIterator, providing auto-close functionality when all of the elements in the iterator are consumed.
ClusteredDataWriter<T>	A data writer capable of writing to multiple specs and partitions that requires the incoming records to be properly clustered by partition spec and by partition within each spec.
ClusteredEqualityDeleteWriter<T>	An equality delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
ClusteredPositionDeleteWriter<T>	A position delete writer capable of writing to multiple specs and partitions that requires the incoming delete records to be properly clustered by partition spec and by partition within each spec.
DataWriter<T>
DataWriteResult	A result of writing data files.
DeleteSchemaUtil
DeleteWriteResult	A result of writing delete files.
FanoutDataWriter<T>	A data writer capable of writing to multiple specs and partitions that keeps data writers for each seen spec/partition pair open until this writer is closed.
FilterIterator<T>	An Iterator that filters another Iterator.
OutputFileFactory	Factory responsible for generating unique but recognizable data file names.
OutputFileFactory.Builder
PartitionedFanoutWriter<T>
PartitionedWriter<T>
PositionOutputStream
ResolvingFileIO	FileIO implementation that uses location scheme to choose the correct FileIO implementation.
RollingDataWriter<T>	A rolling data writer that splits incoming data into multiple files within one spec/partition based on the target file size.
RollingEqualityDeleteWriter<T>	A rolling equality delete writer that splits incoming deletes into multiple files within one spec/partition based on the target file size.
RollingPositionDeleteWriter<T>	A rolling position delete writer that splits incoming deletes into multiple files within one spec/partition based on the target file size.
SeekableInputStream	SeekableInputStream is an interface with the methods needed to read data from a file or Hadoop data stream.
UnpartitionedWriter<T>
WriteResult
WriteResult.Builder