Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
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 | |
org.apache.flink.runtime.webmonitor.handlers.checkpoints |
Modifier and Type | Class and Description |
---|---|
class |
ArchivedExecutionGraph |
class |
ExecutionGraph
The execution graph is the central data structure that coordinates the distributed
execution of a data flow.
|
Modifier and Type | Method and Description |
---|---|
AccessExecutionGraph |
JobManagerMessages.JobFound.executionGraph() |
Constructor and Description |
---|
JobFound(JobID jobID,
AccessExecutionGraph executionGraph) |
Modifier and Type | Method and Description |
---|---|
AccessExecutionGraph |
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(AccessExecutionGraph job) |
Modifier and Type | Method and Description |
---|---|
String |
JobPlanHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
JobExceptionsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
JobDetailsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
JobConfigHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
JobAccumulatorsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
AbstractJobVertexRequestHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
abstract String |
AbstractExecutionGraphRequestHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
Modifier and Type | Method and Description |
---|---|
String |
CheckpointStatsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
CheckpointStatsDetailsSubtasksHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
CheckpointStatsDetailsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
String |
CheckpointConfigHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.