org.apache.flink.runtime.checkpoint.filemerging

Class FileMergingSnapshotManagerBuilder

java.lang.Object

org.apache.flink.runtime.checkpoint.filemerging.FileMergingSnapshotManagerBuilder

public class FileMergingSnapshotManagerBuilder
extends Object

A builder that builds the FileMergingSnapshotManager.

Constructor Summary

Constructors

Constructor and Description
FileMergingSnapshotManagerBuilder(String id) Initialize the builder.

Method Summary

Modifier and Type	Method and Description
FileMergingSnapshotManager	build() Create file-merging snapshot manager based on configuration.
FileMergingSnapshotManagerBuilder	setIOExecutor(Executor ioExecutor) Set the executor for io operation in manager.

Methods inherited from class java.lang.Object

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

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-32072): Create manager during the initialization of task manager services.

TODO (FLINK-32074): Support another type of FileMergingSnapshotManager that merges files across different checkpoints.

Returns:

the created manager.