org.apache.flink.runtime.checkpoint

Interface FinishedTaskStateProvider

All Known Subinterfaces:

CheckpointPlan

All Known Implementing Classes:

DefaultCheckpointPlan

public interface FinishedTaskStateProvider

Collects and fulfills the finished state for the subtasks or operators.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException Thrown when some subtasks of the operator have been finished but state doesn't support that (e.g.

Method Summary

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.

Method Detail

reportTaskFinishedOnRestore

void reportTaskFinishedOnRestore(ExecutionVertex task)

Reports the task is finished on restoring.

reportTaskHasFinishedOperators

void reportTaskHasFinishedOperators(ExecutionVertex task)

Reports the task has finished all the operators.

fulfillFinishedTaskStatus

void fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
                        throws FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException

Fulfills the state for the finished subtasks and operators to indicate they are finished.

Throws:

FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException