BasePositionDeltaWriter<T> |
|
BaseTaskWriter<T> |
|
ByteBufferInputStream |
|
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.
|
ContentCache |
Class that provides file-content caching during reading.
|
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.
|
FileInfo |
|
FileIOParser |
|
FilterIterator<T> |
An Iterator that filters another Iterator.
|
IOUtil |
|
OutputFileFactory |
Factory responsible for generating unique but recognizable data/delete 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 |
|