org.apache.flink.runtime.checkpoint

Interface CheckpointPlan

All Superinterfaces:

FinishedTaskStateProvider

All Known Implementing Classes:

DefaultCheckpointPlan

public interface CheckpointPlan
extends FinishedTaskStateProvider

The plan of one checkpoint, indicating which tasks to trigger, waiting for acknowledge or commit for one specific checkpoint.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.checkpoint.FinishedTaskStateProvider

FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException

Method Summary

Modifier and Type	Method and Description
List<Execution>	getFinishedTasks() Returns tasks that have already been finished when taking the checkpoint.
Collection<ExecutionJobVertex>	getFullyFinishedJobVertex() Returns the job vertices whose tasks are all finished when taking the checkpoint.
List<ExecutionVertex>	getTasksToCommitTo() Returns tasks that are still running when taking the checkpoint, these need to be sent a message when the checkpoint is confirmed.
List<Execution>	getTasksToTrigger() Returns the tasks who need to be sent a message when a checkpoint is started.
List<Execution>	getTasksToWaitFor() Returns tasks who need to acknowledge a checkpoint before it succeeds.
boolean	mayHaveFinishedTasks() Returns whether we support checkpoints after some tasks finished.

Methods inherited from interface org.apache.flink.runtime.checkpoint.FinishedTaskStateProvider

fulfillFinishedTaskStatus, reportTaskFinishedOnRestore, reportTaskHasFinishedOperators

Method Detail

getTasksToTrigger

List<Execution> getTasksToTrigger()

Returns the tasks who need to be sent a message when a checkpoint is started.

getTasksToWaitFor

List<Execution> getTasksToWaitFor()

Returns tasks who need to acknowledge a checkpoint before it succeeds.

getTasksToCommitTo

List<ExecutionVertex> getTasksToCommitTo()

Returns tasks that are still running when taking the checkpoint, these need to be sent a message when the checkpoint is confirmed.

getFinishedTasks

List<Execution> getFinishedTasks()

Returns tasks that have already been finished when taking the checkpoint.

getFullyFinishedJobVertex

@VisibleForTesting
Collection<ExecutionJobVertex> getFullyFinishedJobVertex()

Returns the job vertices whose tasks are all finished when taking the checkpoint.

mayHaveFinishedTasks

boolean mayHaveFinishedTasks()

Returns whether we support checkpoints after some tasks finished.