public static interface StateTransitions.ToRestarting extends StateTransitions
Restarting
state.StateTransitions.ToCancelling, StateTransitions.ToCreatingExecutionGraph, StateTransitions.ToExecuting, StateTransitions.ToFailing, StateTransitions.ToFinished, StateTransitions.ToRestarting, StateTransitions.ToStopWithSavepoint, StateTransitions.ToWaitingForResources
Modifier and Type | Method and Description |
---|---|
void |
goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Restarting state. |
void goToRestarting(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, java.time.Duration backoffTime, List<ExceptionHistoryEntry> failureCollection)
Restarting
state.executionGraph
- executionGraph to pass to the Restarting
stateexecutionGraphHandler
- executionGraphHandler to pass to the Restarting
stateoperatorCoordinatorHandler
- operatorCoordinatorHandler to pas to the Restarting
statebackoffTime
- backoffTime to wait before transitioning to the Restarting
statefailureCollection
- collection of failures that are propagatedCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.