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. |
org.apache.flink.runtime.webmonitor | |
org.apache.flink.runtime.webmonitor.handlers |
Modifier and Type | Method and Description |
---|---|
ExecutionGraph |
ExecutionVertex.getExecutionGraph() |
ExecutionGraph |
ExecutionJobVertex.getGraph() |
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration timeout) |
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration 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) |
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).
|
protected scala.collection.mutable.LinkedHashMap<JobID,ExecutionGraph> |
MemoryArchivist.graphs() |
Modifier and Type | Method and Description |
---|---|
ExecutionGraph |
JobManagerMessages.JobFound.executionGraph() |
ExecutionGraph |
ArchiveMessages.ArchiveExecutionGraph.graph() |
Modifier and Type | Method and Description |
---|---|
Collection<ExecutionGraph> |
ArchiveMessages.ArchivedJobs.asJavaCollection() |
Iterable<ExecutionGraph> |
ArchiveMessages.ArchivedJobs.asJavaIterable() |
Iterable<ExecutionGraph> |
JobManagerMessages.RunningJobs.asJavaIterable() |
scala.Option<ExecutionGraph> |
ArchiveMessages.ArchivedJob.job() |
scala.collection.Iterable<ExecutionGraph> |
ArchiveMessages.ArchivedJobs.jobs() |
scala.collection.Iterable<ExecutionGraph> |
JobManagerMessages.RunningJobs.runningJobs() |
Constructor and Description |
---|
ArchiveExecutionGraph(JobID jobID,
ExecutionGraph graph) |
JobFound(JobID jobID,
ExecutionGraph executionGraph) |
Constructor and Description |
---|
ArchivedJob(scala.Option<ExecutionGraph> job) |
ArchivedJobs(scala.collection.Iterable<ExecutionGraph> jobs) |
RunningJobs(scala.collection.Iterable<ExecutionGraph> runningJobs) |
Modifier and Type | Method and Description |
---|---|
ExecutionGraph |
ExecutionGraphHolder.getExecutionGraph(JobID jid,
ActorGateway jobManager)
Retrieves the execution graph with
JobID jid or null if it cannot be found. |
Modifier and Type | Method and Description |
---|---|
static JobDetails |
WebMonitorUtils.createDetailsForJob(ExecutionGraph job) |
Modifier and Type | Method and Description |
---|---|
String |
JobPlanHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
JobExceptionsHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
JobDetailsHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
JobConfigHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
JobCheckpointsHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
JobAccumulatorsHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
String |
AbstractJobVertexRequestHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
abstract String |
AbstractExecutionGraphRequestHandler.handleRequest(ExecutionGraph graph,
Map<String,String> params) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.