org.apache.flink.runtime.jobgraph.tasks

Class CheckpointCoordinatorConfiguration

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class CheckpointCoordinatorConfiguration
extends Object
implements Serializable

Configuration settings for the CheckpointCoordinator. This includes the checkpoint interval, the checkpoint timeout, the pause between checkpoints, the maximum number of concurrent checkpoints and settings for externalized checkpoints.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CheckpointCoordinatorConfiguration(long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointRetentionPolicy checkpointRetentionPolicy, boolean isExactlyOnce)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getCheckpointInterval()
CheckpointRetentionPolicy	getCheckpointRetentionPolicy()
long	getCheckpointTimeout()
int	getMaxConcurrentCheckpoints()
long	getMinPauseBetweenCheckpoints()
int	hashCode()
boolean	isExactlyOnce()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CheckpointCoordinatorConfiguration

public CheckpointCoordinatorConfiguration(long checkpointInterval,
                                          long checkpointTimeout,
                                          long minPauseBetweenCheckpoints,
                                          int maxConcurrentCheckpoints,
                                          CheckpointRetentionPolicy checkpointRetentionPolicy,
                                          boolean isExactlyOnce)

Method Detail

getCheckpointInterval

public long getCheckpointInterval()

getCheckpointTimeout

public long getCheckpointTimeout()

getMinPauseBetweenCheckpoints

public long getMinPauseBetweenCheckpoints()

getMaxConcurrentCheckpoints

public int getMaxConcurrentCheckpoints()

getCheckpointRetentionPolicy

public CheckpointRetentionPolicy getCheckpointRetentionPolicy()

isExactlyOnce

public boolean isExactlyOnce()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object