public interface FinishedTaskStateProvider
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.
|
void |
reportTaskFinishedOnRestore(ExecutionVertex task)
Reports the
task is finished on restoring. |
void |
reportTaskHasFinishedOperators(ExecutionVertex task)
Reports the
task has finished all the operators. |
void reportTaskFinishedOnRestore(ExecutionVertex task)
task
is finished on restoring.void reportTaskHasFinishedOperators(ExecutionVertex task)
task
has finished all the operators.void fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.