Uses of Interface
org.apache.flink.connector.file.sink.compactor.FileCompactor

Packages that use FileCompactor

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.compactor
org.apache.flink.connector.file.sink.compactor.operator

Uses of FileCompactor in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink with parameters of type FileCompactor

Modifier and Type	Method	Description
T	FileSink.BulkFormatBuilder.enableCompact(FileCompactStrategy strategy, FileCompactor compactor)
T	FileSink.RowFormatBuilder.enableCompact(FileCompactStrategy strategy, FileCompactor compactor)

Uses of FileCompactor in org.apache.flink.connector.file.sink.compactor

Classes in org.apache.flink.connector.file.sink.compactor that implement FileCompactor

Modifier and Type	Class	Description
class	ConcatFileCompactor	A OutputStreamBasedFileCompactor implementation that simply concat the compacting files.
class	IdenticalFileCompactor	A simple OutputStreamBasedFileCompactor implementation that directly copy the content of the only input file to the output.
class	OutputStreamBasedFileCompactor	Base class for FileCompactor implementations that write the compacting file by a output stream.
class	RecordWiseFileCompactor<IN>	A FileCompactor implementation that reads input files with a RecordWiseFileCompactor.Reader and writes with a RecordWiseFileCompactor.Writer.

Uses of FileCompactor in org.apache.flink.connector.file.sink.compactor.operator

Constructors in org.apache.flink.connector.file.sink.compactor.operator with parameters of type FileCompactor

Constructor	Description
CompactorOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters, FileCompactStrategy strategy, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, FileCompactor fileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)
CompactorOperatorFactory(FileCompactStrategy strategy, FileCompactor fileCompactor, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String>,IOException> bucketWriterProvider)
CompactService(int numCompactThreads, FileCompactor fileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)