org.apache.flink.runtime.checkpoint

Class DefaultCheckpointPlanCalculator

java.lang.Object

org.apache.flink.runtime.checkpoint.DefaultCheckpointPlanCalculator

All Implemented Interfaces:

CheckpointPlanCalculator

public class DefaultCheckpointPlanCalculator
extends Object
implements CheckpointPlanCalculator

Default implementation for CheckpointPlanCalculator. If all tasks are running, it directly marks all the sources as tasks to trigger, otherwise it would try to find the running tasks without running processors as tasks to trigger.

Constructor Summary

Constructors

Constructor and Description
DefaultCheckpointPlanCalculator(JobID jobId, CheckpointPlanCalculatorContext context, Iterable<ExecutionJobVertex> jobVerticesInTopologyOrderIterable)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<org.apache.flink.runtime.checkpoint.CheckpointPlan>	calculateCheckpointPlan() Calculates the plan of the next checkpoint.
void	setAllowCheckpointsAfterTasksFinished(boolean allowCheckpointsAfterTasksFinished)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCheckpointPlanCalculator

public DefaultCheckpointPlanCalculator(JobID jobId,
                                       CheckpointPlanCalculatorContext context,
                                       Iterable<ExecutionJobVertex> jobVerticesInTopologyOrderIterable)

Method Detail

setAllowCheckpointsAfterTasksFinished

public void setAllowCheckpointsAfterTasksFinished(boolean allowCheckpointsAfterTasksFinished)

calculateCheckpointPlan

public CompletableFuture<org.apache.flink.runtime.checkpoint.CheckpointPlan> calculateCheckpointPlan()

Description copied from interface: CheckpointPlanCalculator

Calculates the plan of the next checkpoint.

Specified by:

calculateCheckpointPlan in interface CheckpointPlanCalculator

Returns:

The result plan.