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> | |
DataWriter<T> | |
DeleteSchemaUtil | |
FilterIterator<T> |
An Iterator that filters another Iterator.
|
OutputFileFactory |
Factory responsible for generating unique but recognizable data file names.
|
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 |