Package org.apache.iceberg.io
-
Interface Summary Interface Description CloseableIterable<T> CloseableIterator<T> DelegatingInputStream DelegatingOutputStream FileAppender<D> FileAppenderFactory<T> Factory to create a newFileAppenderto write records.FileIO Pluggable module for reading, writing, and deleting files.InputFile An interface used to read input files usingSeekableInputStreaminstances.LocationProvider Interface for providing data file locations to write tasks.OutputFile An interface used to create output files usingPositionOutputStreaminstances.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 SeekableInputStreamis an interface with the methods needed to read data from a file or Hadoop data stream.UnpartitionedWriter<T> WriteResult WriteResult.Builder