Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
HistoryServerArchivist.archiveExecutionGraph(AccessExecutionGraph executionGraph)
Archives the given
AccessExecutionGraph on the history server. |
CompletableFuture<Acknowledge> |
VoidHistoryServerArchivist.archiveExecutionGraph(AccessExecutionGraph executionGraph) |
Modifier and Type | Class and Description |
---|---|
class |
ArchivedExecutionGraph
An archived execution graph represents a serializable form of the
ExecutionGraph . |
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 JobResult |
JobResult.createFrom(AccessExecutionGraph accessExecutionGraph)
Creates the
JobResult from the given AccessExecutionGraph which
must be in a globally terminal state. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends AccessExecutionGraph> |
MiniCluster.getExecutionGraph(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<AccessExecutionGraph> |
DefaultExecutionGraphCache.getExecutionGraph(JobID jobId,
RestfulGateway restfulGateway) |
CompletableFuture<AccessExecutionGraph> |
ExecutionGraphCache.getExecutionGraph(JobID jobId,
RestfulGateway restfulGateway)
Gets the
AccessExecutionGraph for the given JobID and caches it. |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedJson> |
WebMonitorEndpoint.archiveJsonWithPath(AccessExecutionGraph graph) |
static JobDetails |
WebMonitorUtils.createDetailsForJob(AccessExecutionGraph job) |
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–2020 The Apache Software Foundation. All rights reserved.