org.apache.flink.runtime.jobgraph.tasks

Class JobSnapshottingSettings

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.JobSnapshottingSettings

All Implemented Interfaces:

Serializable

public class JobSnapshottingSettings
extends Object
implements Serializable

The JobSnapshottingSettings are attached to a JobGraph and describe the settings for the asynchronous snapshotting of the JobGraph, such as interval, and which vertices need to participate.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_SNAPSHOT_TIMEOUT The default time in which pending checkpoints need to be acknowledged before timing out

Constructor Summary

Constructors

Constructor and Description
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout)

Method Summary

Modifier and Type	Method and Description
long	getCheckpointInterval()
long	getCheckpointTimeout()
List<JobVertexID>	getVerticesToAcknowledge()
List<JobVertexID>	getVerticesToConfirm()
List<JobVertexID>	getVerticesToTrigger()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SNAPSHOT_TIMEOUT

public static final long DEFAULT_SNAPSHOT_TIMEOUT

The default time in which pending checkpoints need to be acknowledged before timing out

See Also:

Constant Field Values

Constructor Detail

JobSnapshottingSettings

public JobSnapshottingSettings(List<JobVertexID> verticesToTrigger,
                               List<JobVertexID> verticesToAcknowledge,
                               List<JobVertexID> verticesToConfirm,
                               long checkpointInterval)

JobSnapshottingSettings

public JobSnapshottingSettings(List<JobVertexID> verticesToTrigger,
                               List<JobVertexID> verticesToAcknowledge,
                               List<JobVertexID> verticesToConfirm,
                               long checkpointInterval,
                               long checkpointTimeout)

Method Detail

getVerticesToTrigger

public List<JobVertexID> getVerticesToTrigger()

getVerticesToAcknowledge

public List<JobVertexID> getVerticesToAcknowledge()

getVerticesToConfirm

public List<JobVertexID> getVerticesToConfirm()

getCheckpointInterval

public long getCheckpointInterval()

getCheckpointTimeout

public long getCheckpointTimeout()

toString

public String toString()

Overrides:

toString in class Object