org.apache.flink.runtime.checkpoint

Interface CheckpointPlanCalculator

All Known Implementing Classes:

DefaultCheckpointPlanCalculator

public interface CheckpointPlanCalculator

Calculates the plan of the next checkpoint, including the tasks to trigger, wait or commit for each checkpoint.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<CheckpointPlan>	calculateCheckpointPlan() Calculates the plan of the next checkpoint.

Method Detail

calculateCheckpointPlan

CompletableFuture<CheckpointPlan> calculateCheckpointPlan()

Calculates the plan of the next checkpoint.

Returns:

The result plan.