Interface AccessExecutionJobVertex
-
- All Known Implementing Classes:
ArchivedExecutionJobVertex
,ExecutionJobVertex
,SpeculativeExecutionJobVertex
public interface AccessExecutionJobVertex
Common interface for the runtimeExecutionJobVertex
andArchivedExecutionJobVertex
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StringifiedAccumulatorResult[]
getAggregatedUserAccumulatorsStringified()
Returns the aggregated user-defined accumulators as strings.ExecutionState
getAggregateState()
Returns the aggregatedExecutionState
for this job vertex.JobVertexID
getJobVertexId()
Returns theJobVertexID
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.AccessExecutionVertex[]
getTaskVertices()
Returns all execution vertices for this job vertex.
-
-
-
Method Detail
-
getName
String getName()
Returns the name for this job vertex.- Returns:
- name for this job vertex.
-
getParallelism
int getParallelism()
Returns the parallelism for this job vertex.- Returns:
- parallelism for this job vertex.
-
getMaxParallelism
int getMaxParallelism()
Returns the max parallelism for this job vertex.- Returns:
- max parallelism for this job vertex.
-
getSlotSharingGroup
SlotSharingGroup getSlotSharingGroup()
Returns the slot sharing group for this job vertex.- Returns:
- slot sharing group for this job vertex.
-
getResourceProfile
ResourceProfile getResourceProfile()
Returns the resource profile for this job vertex.- Returns:
- resource profile for this job vertex.
-
getJobVertexId
JobVertexID getJobVertexId()
Returns theJobVertexID
for this job vertex.- Returns:
- JobVertexID for this job vertex.
-
getTaskVertices
AccessExecutionVertex[] getTaskVertices()
Returns all execution vertices for this job vertex.- Returns:
- all execution vertices for this job vertex
-
getAggregateState
ExecutionState getAggregateState()
Returns the aggregatedExecutionState
for this job vertex.- Returns:
- aggregated state for this job vertex
-
getAggregatedUserAccumulatorsStringified
StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
Returns the aggregated user-defined accumulators as strings.- Returns:
- aggregated user-defined accumulators as strings.
-
-