Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
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,
Executor 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,
Executor 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) |
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
Time timeout,
long createTimestamp) |
Modifier and Type | Method and Description |
---|---|
void |
RestartStrategy.restart(ExecutionGraph executionGraph)
Restarts the given
ExecutionGraph . |
void |
NoRestartStrategy.restart(ExecutionGraph executionGraph) |
void |
FixedDelayRestartStrategy.restart(ExecutionGraph executionGraph) |
void |
FailureRateRestartStrategy.restart(ExecutionGraph executionGraph) |
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–2017 The Apache Software Foundation. All rights reserved.