Package | Description |
---|---|
org.apache.flink.connector.file.sink | |
org.apache.flink.connector.file.sink.compactor | |
org.apache.flink.connector.file.sink.compactor.operator |
Modifier and Type | Method and Description |
---|---|
T |
FileSink.RowFormatBuilder.enableCompact(FileCompactStrategy strategy,
FileCompactor compactor) |
T |
FileSink.BulkFormatBuilder.enableCompact(FileCompactStrategy strategy,
FileCompactor compactor) |
Modifier and Type | Class and 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 . |
Constructor and Description |
---|
CompactorOperator(FileCompactStrategy strategy,
SimpleVersionedSerializer<FileSinkCommittable> committableSerializer,
FileCompactor fileCompactor,
BucketWriter<?,String> bucketWriter) |
CompactorOperatorFactory(FileCompactStrategy strategy,
FileCompactor fileCompactor,
SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier,
SerializableSupplierWithException<BucketWriter<?,String>,IOException> bucketWriterProvider) |
CompactService(int numCompactThreads,
FileCompactor fileCompactor,
BucketWriter<?,String> bucketWriter) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.