public interface AccessExecutionGraph
ExecutionGraph
and ArchivedExecutionGraph
.Modifier and Type | Method and Description |
---|---|
StringifiedAccumulatorResult[] |
getAccumulatorResultsStringified()
Returns the aggregated user-defined accumulators as strings.
|
Map<String,SerializedValue<Object>> |
getAccumulatorsSerialized()
Returns a map containing the serialized values of user-defined accumulators.
|
Iterable<? extends AccessExecutionVertex> |
getAllExecutionVertices()
Returns an iterable containing all execution vertices for this execution graph.
|
Map<JobVertexID,? extends AccessExecutionJobVertex> |
getAllVertices()
Returns a map containing all job vertices for this execution graph.
|
ArchivedExecutionConfig |
getArchivedExecutionConfig()
Returns the
ArchivedExecutionConfig for this execution graph. |
CheckpointCoordinator |
getCheckpointCoordinator()
Returns the
CheckpointCoordinator for this execution graph. |
CheckpointStatsSnapshot |
getCheckpointStatsSnapshot()
Returns a snapshot of the checkpoint statistics or
null if
checkpointing is disabled. |
String |
getFailureCauseAsString()
Returns the exception that caused the job to fail.
|
JobID |
getJobID()
Returns the
JobID for this execution graph. |
String |
getJobName()
Returns the job name for thie execution graph.
|
JobSnapshottingSettings |
getJobSnapshottingSettings()
Returns the
JobSnapshottingSettings or null if
checkpointing is disabled. |
AccessExecutionJobVertex |
getJobVertex(JobVertexID id)
Returns the job vertex for the given
JobVertexID . |
String |
getJsonPlan()
Returns the job plan as a JSON string.
|
JobStatus |
getState()
Returns the current
JobStatus for this execution graph. |
long |
getStatusTimestamp(JobStatus status)
Returns the timestamp for the given
JobStatus |
Iterable<? extends AccessExecutionJobVertex> |
getVerticesTopologically()
Returns an iterable containing all job vertices for this execution graph in the order they were created.
|
boolean |
isArchived()
Returns whether this execution graph was archived.
|
boolean |
isStoppable()
Returns whether the job for this execution graph is stoppable.
|
String getJsonPlan()
JobID getJobID()
JobID
for this execution graph.String getJobName()
JobStatus getState()
JobStatus
for this execution graph.String getFailureCauseAsString()
"(null)"
AccessExecutionJobVertex getJobVertex(JobVertexID id)
JobVertexID
.id
- id of job vertex to be returnedMap<JobVertexID,? extends AccessExecutionJobVertex> getAllVertices()
Iterable<? extends AccessExecutionJobVertex> getVerticesTopologically()
Iterable<? extends AccessExecutionVertex> getAllExecutionVertices()
long getStatusTimestamp(JobStatus status)
JobStatus
status
- status for which the timestamp should be returnedCheckpointCoordinator getCheckpointCoordinator()
CheckpointCoordinator
for this execution graph.null
if none is available.JobSnapshottingSettings getJobSnapshottingSettings()
JobSnapshottingSettings
or null
if
checkpointing is disabled.CheckpointStatsSnapshot getCheckpointStatsSnapshot()
null
if
checkpointing is disabled.ArchivedExecutionConfig getArchivedExecutionConfig()
ArchivedExecutionConfig
for this execution graph.boolean isStoppable()
StringifiedAccumulatorResult[] getAccumulatorResultsStringified()
Map<String,SerializedValue<Object>> getAccumulatorsSerialized() throws IOException
IOException
- indicates that the serialization has failedboolean isArchived()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.