Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover | |
org.apache.flink.runtime.executiongraph.failover.adapter | |
org.apache.flink.runtime.executiongraph.metrics |
This package contains classes implementing various metrics for the job execution,
based on the
Execution Graph . |
org.apache.flink.runtime.executiongraph.restart | |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adapter |
Modifier and Type | Method and Description |
---|---|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
PartitionTracker partitionTracker)
Builds the ExecutionGraph from the JobGraph.
|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
PartitionTracker partitionTracker,
FailoverStrategy.Factory failoverStrategyFactory) |
ExecutionGraph |
ExecutionVertex.getExecutionGraph() |
ExecutionGraph |
ExecutionJobVertex.getGraph() |
Modifier and Type | Method and Description |
---|---|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
PartitionTracker partitionTracker)
Builds the ExecutionGraph from the JobGraph.
|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time rpcTimeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
PartitionTracker partitionTracker,
FailoverStrategy.Factory failoverStrategyFactory) |
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
static CompletableFuture<Void> |
SchedulingUtils.schedule(ScheduleMode scheduleMode,
Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph) |
static CompletableFuture<Void> |
SchedulingUtils.scheduleEager(Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph)
Schedule vertices eagerly.
|
static CompletableFuture<Void> |
SchedulingUtils.scheduleLazy(Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph)
Schedule vertices lazy.
|
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
int maxPriorAttemptsHistoryLength,
Time timeout,
long initialGlobalModVersion,
long createTimestamp) |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
RestartAllStrategy.Factory.create(ExecutionGraph executionGraph) |
RestartIndividualStrategy |
RestartIndividualStrategy.Factory.create(ExecutionGraph executionGraph) |
FailoverStrategy |
AdaptedRestartPipelinedRegionStrategyNG.Factory.create(ExecutionGraph executionGraph) |
FailoverStrategy |
FailoverStrategy.Factory.create(ExecutionGraph executionGraph)
Instantiates the
FailoverStrategy . |
FailoverStrategy |
RestartPipelinedRegionStrategy.Factory.create(ExecutionGraph executionGraph) |
protected FailoverRegion |
RestartPipelinedRegionStrategy.createFailoverRegion(ExecutionGraph eg,
List<ExecutionVertex> connectedExecutions) |
Constructor and Description |
---|
AdaptedRestartPipelinedRegionStrategyNG(ExecutionGraph executionGraph) |
FailoverRegion(ExecutionGraph executionGraph,
List<ExecutionVertex> connectedExecutions,
Map<JobVertexID,ExecutionJobVertex> tasks) |
RestartAllStrategy(ExecutionGraph executionGraph)
Creates a new failover strategy that recovers from failures by restarting all tasks
of the execution graph.
|
RestartIndividualStrategy(ExecutionGraph executionGraph)
Creates a new failover strategy that recovers from failures by restarting only the failed task
of the execution graph.
|
RestartPipelinedRegionStrategy(ExecutionGraph executionGraph)
Creates a new failover strategy to restart pipelined regions that works on the given
execution graph.
|
Constructor and Description |
---|
DefaultFailoverTopology(ExecutionGraph executionGraph) |
Constructor and Description |
---|
DownTimeGauge(ExecutionGraph executionGraph) |
NumberOfFullRestartsGauge(ExecutionGraph executionGraph) |
RestartTimeGauge(ExecutionGraph executionGraph) |
UpTimeGauge(ExecutionGraph executionGraph) |
Constructor and Description |
---|
ExecutionGraphRestartCallback(ExecutionGraph execGraph,
long expectedGlobalModVersion)
Creates a new ExecutionGraphRestartCallback.
|
Constructor and Description |
---|
ExecutionGraphToInputsLocationsRetrieverAdapter(ExecutionGraph executionGraph) |
Constructor and Description |
---|
ExecutionGraphToSchedulingTopologyAdapter(ExecutionGraph graph) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.