Interface StateTransitions.ToStopWithSavepoint
-
- All Superinterfaces:
StateTransitions
- All Known Implementing Classes:
AdaptiveScheduler
- Enclosing interface:
- StateTransitions
public static interface StateTransitions.ToStopWithSavepoint extends StateTransitions
Interface covering transition to theStopWithSavepoint
state.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.runtime.scheduler.adaptive.StateTransitions
StateTransitions.ToCancelling, StateTransitions.ToCreatingExecutionGraph, StateTransitions.ToExecuting, StateTransitions.ToFailing, StateTransitions.ToFinished, StateTransitions.ToRestarting, StateTransitions.ToStopWithSavepoint, StateTransitions.ToWaitingForResources
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<String>
goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection)
Transitions into theStopWithSavepoint
state.
-
-
-
Method Detail
-
goToStopWithSavepoint
CompletableFuture<String> goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection)
Transitions into theStopWithSavepoint
state.- Parameters:
executionGraph
- executionGraph to pass to theStopWithSavepoint
stateexecutionGraphHandler
- executionGraphHandler to pass to theStopWithSavepoint
stateoperatorCoordinatorHandler
- operatorCoordinatorHandler to pass to theStopWithSavepoint
statesavepointFuture
- Future for the savepoint to complete.failureCollection
- collection of failures that are propagated- Returns:
- Location of the savepoint.
-
-