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 | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
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 timeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
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 timeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
Time timeout,
long initialGlobalModVersion,
long createTimestamp) |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
RestartPipelinedRegionStrategy.Factory.create(ExecutionGraph executionGraph) |
RestartIndividualStrategy |
RestartIndividualStrategy.Factory.create(ExecutionGraph executionGraph) |
FailoverStrategy |
RestartAllStrategy.Factory.create(ExecutionGraph executionGraph) |
FailoverStrategy |
FailoverStrategy.Factory.create(ExecutionGraph executionGraph)
Instantiates the
FailoverStrategy . |
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.
|
Modifier and Type | Method and Description |
---|---|
protected scala.collection.mutable.HashMap<JobID,scala.Tuple2<ExecutionGraph,JobInfo>> |
JobManager.currentJobs()
Either running or not yet archived jobs (session hasn't been ended).
|
Modifier and Type | Method and Description |
---|---|
Iterable<ExecutionGraph> |
JobManagerMessages.RunningJobs.asJavaIterable() |
scala.collection.Iterable<ExecutionGraph> |
JobManagerMessages.RunningJobs.runningJobs() |
Constructor and Description |
---|
RunningJobs(scala.collection.Iterable<ExecutionGraph> runningJobs) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.