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	Description
`FileMergingSnapshotManagerBuilder(JobID jobId, ResourceID tmResourceId, FileMergingType type)`	Initialize the builder.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`FileMergingSnapshotManager`	`build()`	Create file-merging snapshot manager based on configuration.
`FileMergingSnapshotManagerBuilder`	`setFilePoolType(PhysicalFilePool.Type filePoolType)`	Set the type of physical file pool.
`FileMergingSnapshotManagerBuilder`	`setIOExecutor(Executor ioExecutor)`	Set the executor for io operation in manager.
`FileMergingSnapshotManagerBuilder`	`setMaxFileSize(long maxFileSize)`	Set the max file size.
`FileMergingSnapshotManagerBuilder`	`setMaxSpaceAmplification(float amplification)`
`FileMergingSnapshotManagerBuilder`	`setMetricGroup(TaskManagerJobMetricGroup metricGroup)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileMergingSnapshotManagerBuilder

public FileMergingSnapshotManagerBuilder(JobID jobId,
                                         ResourceID tmResourceId,
                                         FileMergingType type)

Initialize the builder.

Parameters:: id - the id of the manager.

Method Detail

setMaxFileSize

public FileMergingSnapshotManagerBuilder setMaxFileSize(long maxFileSize)

Set the max file size.

setFilePoolType

public FileMergingSnapshotManagerBuilder setFilePoolType(PhysicalFilePool.Type filePoolType)

Set the type of physical file pool.

setMaxSpaceAmplification

public FileMergingSnapshotManagerBuilder setMaxSpaceAmplification(float amplification)

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.

setMetricGroup

public FileMergingSnapshotManagerBuilder setMetricGroup(TaskManagerJobMetricGroup metricGroup)

build
```
public FileMergingSnapshotManager build()
```
Create file-merging snapshot manager based on configuration.

Returns:

the created manager.

Class FileMergingSnapshotManagerBuilder