Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.history | |
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 | |
org.apache.flink.runtime.webmonitor.history |
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 |
---|---|
static Path |
FsJobArchivist.archiveJob(Path rootPath,
AccessExecutionGraph graph)
Writes the given
AccessExecutionGraph to the FileSystem pointed to by
JobManagerOptions.ARCHIVE_DIR . |
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 |
---|---|
Collection<ArchivedJson> |
SubtasksTimesHandler.SubtasksTimesJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtasksAllAccumulatorsHandler.SubtasksAllAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtaskExecutionAttemptDetailsHandler.SubtaskExecutionAttemptDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtaskExecutionAttemptAccumulatorsHandler.SubtaskExecutionAttemptAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexTaskManagersHandler.JobVertexTaskManagersJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexDetailsHandler.JobVertexDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexAccumulatorsHandler.JobVertexAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobPlanHandler.JobPlanJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobExceptionsHandler.JobExceptionsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobDetailsHandler.JobDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobConfigHandler.JobConfigJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobAccumulatorsHandler.JobAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
CurrentJobsOverviewHandler.CurrentJobsOverviewJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
static String |
JobAccumulatorsHandler.createJobAccumulatorsJson(AccessExecutionGraph graph) |
static String |
JobConfigHandler.createJobConfigJson(AccessExecutionGraph graph) |
static String |
JobDetailsHandler.createJobDetailsJson(AccessExecutionGraph graph,
MetricFetcher fetcher) |
static String |
JobExceptionsHandler.createJobExceptionsJson(AccessExecutionGraph graph) |
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 |
---|---|
Collection<ArchivedJson> |
CheckpointStatsHandler.CheckpointStatsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
CheckpointStatsDetailsSubtasksHandler.CheckpointStatsDetailsSubtasksJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
CheckpointStatsDetailsHandler.CheckpointStatsDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
CheckpointConfigHandler.CheckpointConfigJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
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) |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedJson> |
JsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph)
Returns a
Collection of ArchivedJson s containing JSON responses and their respective REST URL
for a given job. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.