Class FileCompactStrategy.Builder
- java.lang.Object
-
- org.apache.flink.connector.file.sink.compactor.FileCompactStrategy.Builder
-
- Enclosing class:
- FileCompactStrategy
public static class FileCompactStrategy.Builder extends Object
Builder forFileCompactStrategy
.
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description FileCompactStrategy
build()
FileCompactStrategy.Builder
enableCompactionOnCheckpoint(int numCheckpointsBeforeCompaction)
Optional, compaction will be triggered when N checkpoints passed since the last triggering, -1 by default indicating no compaction on checkpoint.static FileCompactStrategy.Builder
newBuilder()
FileCompactStrategy.Builder
setNumCompactThreads(int numCompactThreads)
Optional, the count of compacting threads in a compactor operator, 1 by default.FileCompactStrategy.Builder
setSizeThreshold(long sizeThreshold)
Optional, compaction will be triggered when the total size of compacting files reaches the threshold. -1 by default, indicating the size is unlimited.
-
-
-
Method Detail
-
newBuilder
public static FileCompactStrategy.Builder newBuilder()
-
enableCompactionOnCheckpoint
public FileCompactStrategy.Builder enableCompactionOnCheckpoint(int numCheckpointsBeforeCompaction)
Optional, compaction will be triggered when N checkpoints passed since the last triggering, -1 by default indicating no compaction on checkpoint.
-
setSizeThreshold
public FileCompactStrategy.Builder setSizeThreshold(long sizeThreshold)
Optional, compaction will be triggered when the total size of compacting files reaches the threshold. -1 by default, indicating the size is unlimited.
-
setNumCompactThreads
public FileCompactStrategy.Builder setNumCompactThreads(int numCompactThreads)
Optional, the count of compacting threads in a compactor operator, 1 by default.
-
build
public FileCompactStrategy build()
-
-