Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adaptive |
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutionGraph
Default implementation of the
ExecutionGraph . |
Modifier and Type | Method and Description |
---|---|
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph,
JobStatus statusOverride)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
Constructor and Description |
---|
ExecutionGraphCheckpointPlanCalculatorContext(ExecutionGraph executionGraph) |
Modifier and Type | Method and Description |
---|---|
ExecutionGraph |
DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
org.slf4j.Logger log) |
ExecutionGraph |
ExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
org.slf4j.Logger log)
Create and restore
ExecutionGraph from the given JobGraph and services. |
ExecutionGraph |
SchedulerBase.getExecutionGraph()
ExecutionGraph is exposed to make it easier to rework tests to be based on the new scheduler.
|
Constructor and Description |
---|
DefaultOperatorCoordinatorHandler(ExecutionGraph executionGraph,
java.util.function.Consumer<Throwable> globalFailureHandler) |
ExecutionGraphHandler(ExecutionGraph executionGraph,
org.slf4j.Logger log,
Executor ioExecutor,
ComponentMainThreadExecutor mainThreadExecutor) |
ExecutionGraphToInputsLocationsRetrieverAdapter(ExecutionGraph executionGraph) |
KvStateHandler(ExecutionGraph executionGraph) |
Modifier and Type | Method and Description |
---|---|
boolean |
AdaptiveScheduler.canScaleUp(ExecutionGraph executionGraph) |
void |
AdaptiveScheduler.goToCanceling(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler) |
void |
AdaptiveScheduler.goToExecuting(ExecutionGraph executionGraph) |
void |
AdaptiveScheduler.goToExecuting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler) |
void |
AdaptiveScheduler.goToFailing(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
Throwable failureCause) |
void |
AdaptiveScheduler.goToRestarting(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
java.time.Duration backoffTime) |
CompletableFuture<String> |
AdaptiveScheduler.goToStopWithSavepoint(ExecutionGraph executionGraph,
ExecutionGraphHandler executionGraphHandler,
OperatorCoordinatorHandler operatorCoordinatorHandler,
CheckpointScheduling checkpointScheduling,
CompletableFuture<String> savepointFuture) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.