public class DefaultCheckpointPlan extends Object implements CheckpointPlan
CheckpointPlan
.FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException
Modifier and Type | Method and Description |
---|---|
void |
fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
Fulfills the state for the finished subtasks and operators to indicate they are finished.
|
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.
|
void |
reportTaskFinishedOnRestore(ExecutionVertex task)
Reports the
task is finished on restoring. |
void |
reportTaskHasFinishedOperators(ExecutionVertex task)
Reports the
task has finished all the operators. |
public List<Execution> getTasksToTrigger()
CheckpointPlan
getTasksToTrigger
in interface CheckpointPlan
public List<Execution> getTasksToWaitFor()
CheckpointPlan
getTasksToWaitFor
in interface CheckpointPlan
public List<ExecutionVertex> getTasksToCommitTo()
CheckpointPlan
getTasksToCommitTo
in interface CheckpointPlan
public List<Execution> getFinishedTasks()
CheckpointPlan
getFinishedTasks
in interface CheckpointPlan
public Collection<ExecutionJobVertex> getFullyFinishedJobVertex()
CheckpointPlan
getFullyFinishedJobVertex
in interface CheckpointPlan
public boolean mayHaveFinishedTasks()
CheckpointPlan
mayHaveFinishedTasks
in interface CheckpointPlan
public void reportTaskFinishedOnRestore(ExecutionVertex task)
FinishedTaskStateProvider
task
is finished on restoring.reportTaskFinishedOnRestore
in interface FinishedTaskStateProvider
public void reportTaskHasFinishedOperators(ExecutionVertex task)
FinishedTaskStateProvider
task
has finished all the operators.reportTaskHasFinishedOperators
in interface FinishedTaskStateProvider
public void fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
FinishedTaskStateProvider
fulfillFinishedTaskStatus
in interface FinishedTaskStateProvider
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.