Package org.apache.iceberg.io
-
Interface Summary Interface Description CloseableIterable<T> CloseableIterator<T> DelegatingInputStream DelegatingOutputStream FileAppender<D> FileAppenderFactory<T> Factory to create a newFileAppender
to write records.FileIO Pluggable module for reading, writing, and deleting files.InputFile An interface used to read input files usingSeekableInputStream
instances.LocationProvider Interface for providing data file locations to write tasks.OutputFile An interface used to create output files usingPositionOutputStream
instances.TaskWriter<T> The writer interface could accept records and provide the generated data files.WriterFactory<T> A factory for creating data and delete writers. -
Class Summary Class Description BaseTaskWriter<T> CloseableGroup CloseableIterable.ConcatCloseableIterable<E> ClosingIterator<T> A convenience wrapper aroundCloseableIterator
, providing auto-close functionality when all of the elements in the iterator are consumed.DataWriter<T> DeleteSchemaUtil 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 SeekableInputStream SeekableInputStream
is an interface with the methods needed to read data from a file or Hadoop data stream.UnpartitionedWriter<T> WriteResult WriteResult.Builder