public class ArchivedExecutionGraph extends Object implements AccessExecutionGraph, Serializable
Constructor and Description |
---|
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
String failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<Object>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
JobCheckpointingSettings jobCheckpointingSettings,
CheckpointStatsSnapshot checkpointStatsSnapshot) |
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<ArchivedExecutionVertex> |
getAllExecutionVertices()
Returns an iterable containing all execution vertices for this execution graph.
|
Map<JobVertexID,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.
|
JobCheckpointingSettings |
getJobCheckpointingSettings()
Returns the
JobCheckpointingSettings or null if
checkpointing is disabled. |
JobID |
getJobID()
Returns the
JobID for this execution graph. |
String |
getJobName()
Returns the job name for thie execution graph.
|
ArchivedExecutionJobVertex |
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 |
StringifiedAccumulatorResult[] |
getUserAccumulators() |
Iterable<ArchivedExecutionJobVertex> |
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.
|
public ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, String failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<Object>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, @Nullable JobCheckpointingSettings jobCheckpointingSettings, @Nullable CheckpointStatsSnapshot checkpointStatsSnapshot)
public String getJsonPlan()
AccessExecutionGraph
getJsonPlan
in interface AccessExecutionGraph
public JobID getJobID()
AccessExecutionGraph
JobID
for this execution graph.getJobID
in interface AccessExecutionGraph
public String getJobName()
AccessExecutionGraph
getJobName
in interface AccessExecutionGraph
public JobStatus getState()
AccessExecutionGraph
JobStatus
for this execution graph.getState
in interface AccessExecutionGraph
public String getFailureCauseAsString()
AccessExecutionGraph
getFailureCauseAsString
in interface AccessExecutionGraph
"(null)"
public ArchivedExecutionJobVertex getJobVertex(JobVertexID id)
AccessExecutionGraph
JobVertexID
.getJobVertex
in interface AccessExecutionGraph
id
- id of job vertex to be returnedpublic Map<JobVertexID,AccessExecutionJobVertex> getAllVertices()
AccessExecutionGraph
getAllVertices
in interface AccessExecutionGraph
public Iterable<ArchivedExecutionJobVertex> getVerticesTopologically()
AccessExecutionGraph
getVerticesTopologically
in interface AccessExecutionGraph
public Iterable<ArchivedExecutionVertex> getAllExecutionVertices()
AccessExecutionGraph
getAllExecutionVertices
in interface AccessExecutionGraph
public long getStatusTimestamp(JobStatus status)
AccessExecutionGraph
JobStatus
getStatusTimestamp
in interface AccessExecutionGraph
status
- status for which the timestamp should be returnedpublic CheckpointCoordinator getCheckpointCoordinator()
AccessExecutionGraph
CheckpointCoordinator
for this execution graph.getCheckpointCoordinator
in interface AccessExecutionGraph
null
if none is available.public JobCheckpointingSettings getJobCheckpointingSettings()
AccessExecutionGraph
JobCheckpointingSettings
or null
if
checkpointing is disabled.getJobCheckpointingSettings
in interface AccessExecutionGraph
public CheckpointStatsSnapshot getCheckpointStatsSnapshot()
AccessExecutionGraph
null
if
checkpointing is disabled.getCheckpointStatsSnapshot
in interface AccessExecutionGraph
public boolean isArchived()
AccessExecutionGraph
isArchived
in interface AccessExecutionGraph
public StringifiedAccumulatorResult[] getUserAccumulators()
public ArchivedExecutionConfig getArchivedExecutionConfig()
AccessExecutionGraph
ArchivedExecutionConfig
for this execution graph.getArchivedExecutionConfig
in interface AccessExecutionGraph
public boolean isStoppable()
AccessExecutionGraph
isStoppable
in interface AccessExecutionGraph
public StringifiedAccumulatorResult[] getAccumulatorResultsStringified()
AccessExecutionGraph
getAccumulatorResultsStringified
in interface AccessExecutionGraph
public Map<String,SerializedValue<Object>> getAccumulatorsSerialized()
AccessExecutionGraph
getAccumulatorsSerialized
in interface AccessExecutionGraph
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.