| Interface | Description |
|---|---|
| CloseableIterable<T> | |
| CloseableIterator<T> | |
| DelegatingInputStream | |
| DelegatingOutputStream | |
| FileAppender<D> | |
| FileAppenderFactory<T> |
Factory to create a new
FileAppender to write records. |
| FileIO |
Pluggable module for reading, writing, and deleting files.
|
| 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. |
| TaskWriter<T> |
The writer interface could accept records and provide the generated data files.
|
| Class | Description |
|---|---|
| BaseTaskWriter<T> | |
| CloseableGroup | |
| CloseableIterable.ConcatCloseableIterable<E> | |
| ClosingIterator<T> | |
| FilterIterator<T> |
An Iterator that filters another Iterator.
|
| OutputFileFactory | |
| PartitionedWriter<T> | |
| PositionOutputStream | |
| SeekableInputStream |
SeekableInputStream is an interface with the methods needed to read data from a file or
Hadoop data stream. |
| UnpartitionedWriter<T> |