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 | Method and Description |
---|---|
FileCompactStrategy |
FileCompactStrategy.Builder.build() |
Constructor and Description |
---|
CompactCoordinator(FileCompactStrategy strategy,
SimpleVersionedSerializer<FileSinkCommittable> committableSerializer) |
CompactCoordinatorFactory(FileCompactStrategy strategy,
SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier) |
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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.