ConcatFileCompactor |
|
DecoderBasedReader |
|
DecoderBasedReader.Decoder |
|
DecoderBasedReader.Decoder.Factory |
|
FileCompactor |
The FileCompactor is responsible for compacting files into one file.
|
FileCompactStrategy |
Strategy for compacting the files written in FileSink before committing.
|
FileCompactStrategy.Builder |
|
InputFormatBasedReader |
|
OutputStreamBasedFileCompactor |
Base class for FileCompactor implementations that write the compacting file by a output
stream.
|
RecordWiseFileCompactor.Reader |
The reader that reads record from the compacting files.
|
RecordWiseFileCompactor.Reader.Factory |
|
RecordWiseFileCompactor.Writer |
The writer that writers record into the compacting files.
|