public class ArchivedExecutionJobVertex extends Object implements AccessExecutionJobVertex, Serializable
Constructor and Description |
---|
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
StringifiedAccumulatorResult[] archivedUserAccumulators) |
ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex) |
Modifier and Type | Method and Description |
---|---|
StringifiedAccumulatorResult[] |
getAggregatedUserAccumulatorsStringified()
Returns the aggregated user-defined accumulators as strings.
|
ExecutionState |
getAggregateState()
Returns the aggregated
ExecutionState for this job vertex. |
JobVertexID |
getJobVertexId()
Returns the
JobVertexID for this job vertex. |
int |
getMaxParallelism()
Returns the max parallelism for this job vertex.
|
String |
getName()
Returns the name for this job vertex.
|
int |
getParallelism()
Returns the parallelism for this job vertex.
|
ArchivedExecutionVertex[] |
getTaskVertices()
Returns all execution vertices for this job vertex.
|
public ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex)
public ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices, JobVertexID id, String name, int parallelism, int maxParallelism, StringifiedAccumulatorResult[] archivedUserAccumulators)
public String getName()
AccessExecutionJobVertex
getName
in interface AccessExecutionJobVertex
public int getParallelism()
AccessExecutionJobVertex
getParallelism
in interface AccessExecutionJobVertex
public int getMaxParallelism()
AccessExecutionJobVertex
getMaxParallelism
in interface AccessExecutionJobVertex
public JobVertexID getJobVertexId()
AccessExecutionJobVertex
JobVertexID
for this job vertex.getJobVertexId
in interface AccessExecutionJobVertex
public ArchivedExecutionVertex[] getTaskVertices()
AccessExecutionJobVertex
getTaskVertices
in interface AccessExecutionJobVertex
public ExecutionState getAggregateState()
AccessExecutionJobVertex
ExecutionState
for this job vertex.getAggregateState
in interface AccessExecutionJobVertex
public StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
AccessExecutionJobVertex
getAggregatedUserAccumulatorsStringified
in interface AccessExecutionJobVertex
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.