org.apache.flink.runtime.jobgraph.tasks

Class CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder

Enclosing class:

CheckpointCoordinatorConfiguration

public static class CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder
extends Object

CheckpointCoordinatorConfiguration builder.

Constructor Summary

Constructors

Constructor and Description
CheckpointCoordinatorConfigurationBuilder()

Method Summary

Modifier and Type	Method and Description
CheckpointCoordinatorConfiguration	build()
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setAlignedCheckpointTimeout(long alignedCheckpointTimeout)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setCheckpointIdOfIgnoredInFlightData(long checkpointIdOfIgnoredInFlightData)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setCheckpointInterval(long checkpointInterval)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setCheckpointRetentionPolicy(CheckpointRetentionPolicy checkpointRetentionPolicy)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setCheckpointTimeout(long checkpointTimeout)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setEnableCheckpointsAfterTasksFinish(boolean enableCheckpointsAfterTasksFinish)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setExactlyOnce(boolean exactlyOnce)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setMaxConcurrentCheckpoints(int maxConcurrentCheckpoints)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setMinPauseBetweenCheckpoints(long minPauseBetweenCheckpoints)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setTolerableCheckpointFailureNumber(int tolerableCheckpointFailureNumber)
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder	setUnalignedCheckpointsEnabled(boolean unalignedCheckpointsEnabled)

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointCoordinatorConfigurationBuilder

public CheckpointCoordinatorConfigurationBuilder()

Method Detail

build

public CheckpointCoordinatorConfiguration build()

setCheckpointInterval

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointInterval(long checkpointInterval)

setCheckpointTimeout

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointTimeout(long checkpointTimeout)

setMinPauseBetweenCheckpoints

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setMinPauseBetweenCheckpoints(long minPauseBetweenCheckpoints)

setMaxConcurrentCheckpoints

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setMaxConcurrentCheckpoints(int maxConcurrentCheckpoints)

setCheckpointRetentionPolicy

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointRetentionPolicy(CheckpointRetentionPolicy checkpointRetentionPolicy)

setExactlyOnce

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setExactlyOnce(boolean exactlyOnce)

setTolerableCheckpointFailureNumber

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setTolerableCheckpointFailureNumber(int tolerableCheckpointFailureNumber)

setUnalignedCheckpointsEnabled

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setUnalignedCheckpointsEnabled(boolean unalignedCheckpointsEnabled)

setAlignedCheckpointTimeout

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setAlignedCheckpointTimeout(long alignedCheckpointTimeout)

setCheckpointIdOfIgnoredInFlightData

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setCheckpointIdOfIgnoredInFlightData(long checkpointIdOfIgnoredInFlightData)

setEnableCheckpointsAfterTasksFinish

public CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder setEnableCheckpointsAfterTasksFinish(boolean enableCheckpointsAfterTasksFinish)