public class ExecutionGraphCheckpointPlanCalculatorContext extends Object implements CheckpointPlanCalculatorContext
CheckpointPlanCalculatorContext
implementation based on the information from an ExecutionGraph
.Constructor and Description |
---|
ExecutionGraphCheckpointPlanCalculatorContext(ExecutionGraph executionGraph) |
Modifier and Type | Method and Description |
---|---|
ScheduledExecutor |
getMainExecutor()
Acquires the main thread executor for this job.
|
boolean |
hasFinishedTasks()
Detects whether there are already some tasks finished.
|
public ExecutionGraphCheckpointPlanCalculatorContext(ExecutionGraph executionGraph)
public ScheduledExecutor getMainExecutor()
CheckpointPlanCalculatorContext
getMainExecutor
in interface CheckpointPlanCalculatorContext
public boolean hasFinishedTasks()
CheckpointPlanCalculatorContext
hasFinishedTasks
in interface CheckpointPlanCalculatorContext
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.