public class DefaultCheckpointPlanCalculator extends Object implements CheckpointPlanCalculator
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 and Description|
|Modifier and Type||Method and Description|
Calculates the plan of the next checkpoint.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.