Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover | |
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 |
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)
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,
int parallelismForAutoMax,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log)
Deprecated.
|
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)
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,
int parallelismForAutoMax,
BlobWriter blobWriter,
Time allocationTimeout,
org.slf4j.Logger log)
Deprecated.
|
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
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 |
FailoverStrategy.Factory.create(ExecutionGraph executionGraph)
Instantiates the
FailoverStrategy . |
FailoverStrategy |
RestartPipelinedRegionStrategy.Factory.create(ExecutionGraph executionGraph) |
Constructor and Description |
---|
FailoverRegion(ExecutionGraph executionGraph,
Executor executor,
List<ExecutionVertex> connectedExecutions) |
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.
|
RestartIndividualStrategy(ExecutionGraph executionGraph,
Executor callbackExecutor)
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 and uses the execution graph's future executor to call restart actions.
|
RestartPipelinedRegionStrategy(ExecutionGraph executionGraph,
Executor executor)
Creates a new failover strategy to restart pipelined regions that works on the given
execution graph and uses the given executor to call restart actions.
|
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.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.