Uses of Package
org.apache.flink.connector.file.sink.compactor
-
Classes in org.apache.flink.connector.file.sink.compactor used by org.apache.flink.connector.file.sink Class Description FileCompactor TheFileCompactoris responsible for compacting files into one file.FileCompactStrategy Strategy for compacting the files written inFileSinkbefore committing. -
Classes in org.apache.flink.connector.file.sink.compactor used by org.apache.flink.connector.file.sink.compactor Class Description ConcatFileCompactor AOutputStreamBasedFileCompactorimplementation that simply concat the compacting files.DecoderBasedReader ARecordWiseFileCompactor.Readerimplementation that reads the file as anFSDataInputStreamand decodes the record with theDecoderBasedReader.Decoder.DecoderBasedReader.Decoder ADecoderBasedReader.Decoderto decode the file content into the actual records.DecoderBasedReader.Decoder.Factory Factory to createDecoderBasedReader.Decoder.FileCompactor TheFileCompactoris responsible for compacting files into one file.FileCompactStrategy Strategy for compacting the files written inFileSinkbefore committing.FileCompactStrategy.Builder Builder forFileCompactStrategy.InputFormatBasedReader ARecordWiseFileCompactor.Readerimplementation that reads the file using theFileInputFormat.OutputStreamBasedFileCompactor Base class forFileCompactorimplementations that write the compacting file by a output stream.RecordWiseFileCompactor.Reader The reader that reads record from the compacting files.RecordWiseFileCompactor.Reader.Factory Factory forRecordWiseFileCompactor.Reader.RecordWiseFileCompactor.Writer The writer that writers record into the compacting files. -
Classes in org.apache.flink.connector.file.sink.compactor used by org.apache.flink.connector.file.sink.compactor.operator Class Description FileCompactor TheFileCompactoris responsible for compacting files into one file.FileCompactStrategy Strategy for compacting the files written inFileSinkbefore committing.