Class FileMergingSnapshotManagerBuilder
- java.lang.Object
-
- org.apache.flink.runtime.checkpoint.filemerging.FileMergingSnapshotManagerBuilder
-
public class FileMergingSnapshotManagerBuilder extends Object
A builder that builds theFileMergingSnapshotManager.
-
-
Constructor Summary
Constructors Constructor Description FileMergingSnapshotManagerBuilder(String id)Initialize the builder.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FileMergingSnapshotManagerbuild()Create file-merging snapshot manager based on configuration.FileMergingSnapshotManagerBuildersetIOExecutor(Executor ioExecutor)Set the executor for io operation in manager.
-
-
-
Constructor Detail
-
FileMergingSnapshotManagerBuilder
public FileMergingSnapshotManagerBuilder(String id)
Initialize the builder.- Parameters:
id- the id of the manager.
-
-
Method Detail
-
setIOExecutor
public FileMergingSnapshotManagerBuilder setIOExecutor(@Nullable Executor ioExecutor)
Set the executor for io operation in manager. If null(default), all io operation will be executed synchronously.
-
build
public FileMergingSnapshotManager build()
Create file-merging snapshot manager based on configuration.TODO (FLINK-32074): Support another type of FileMergingSnapshotManager that merges files across different checkpoints.
- Returns:
- the created manager.
-
-