Package | Description |
---|---|
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adaptive |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOperatorCoordinatorHandler
Default handler for the
OperatorCoordinators . |
Modifier and Type | Field and Description |
---|---|
protected OperatorCoordinatorHandler |
SchedulerBase.operatorCoordinatorHandler |
Modifier and Type | Method and Description |
---|---|
void |
StateTransitions.ToCancelling.goToCanceling(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Canceling state. |
void |
AdaptiveScheduler.goToCanceling(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToExecuting.goToExecuting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Executing state. |
void |
AdaptiveScheduler.goToExecuting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToFailing.goToFailing(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
Throwable failureCause,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Failing state. |
void |
AdaptiveScheduler.goToFailing(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
Throwable failureCause,
List<ExceptionHistoryEntry> failureCollection) |
void |
StateTransitions.ToRestarting.goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
Restarting state. |
void |
AdaptiveScheduler.goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime,
List<ExceptionHistoryEntry> failureCollection) |
CompletableFuture<String> |
StateTransitions.ToStopWithSavepoint.goToStopWithSavepoint(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
CheckpointScheduling checkpointScheduling,
CompletableFuture<String> savepointFuture,
List<ExceptionHistoryEntry> failureCollection)
Transitions into the
StopWithSavepoint state. |
CompletableFuture<String> |
AdaptiveScheduler.goToStopWithSavepoint(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
CheckpointScheduling checkpointScheduling,
CompletableFuture<String> savepointFuture,
List<ExceptionHistoryEntry> failureCollection) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.