org.apache.flink.connector.file.sink.compactor

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 for FileCompactStrategy.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

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()