public class ArchivedExecutionJobVertex extends Object implements AccessExecutionJobVertex, Serializable
Constructor and Description |
---|
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
SlotSharingGroup slotSharingGroup,
ResourceProfile resourceProfile,
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.
|
ResourceProfile |
getResourceProfile()
Returns the resource profile for this job vertex.
|
SlotSharingGroup |
getSlotSharingGroup()
Returns the slot sharing group 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, SlotSharingGroup slotSharingGroup, ResourceProfile resourceProfile, 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 SlotSharingGroup getSlotSharingGroup()
AccessExecutionJobVertex
getSlotSharingGroup
in interface AccessExecutionJobVertex
public ResourceProfile getResourceProfile()
AccessExecutionJobVertex
getResourceProfile
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–2024 The Apache Software Foundation. All rights reserved.