public interface AccessExecutionJobVertex
ExecutionJobVertex
and ArchivedExecutionJobVertex
.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.
|
AccessExecutionVertex[] |
getTaskVertices()
Returns all execution vertices for this job vertex.
|
String getName()
int getParallelism()
int getMaxParallelism()
JobVertexID getJobVertexId()
JobVertexID
for this job vertex.AccessExecutionVertex[] getTaskVertices()
ExecutionState getAggregateState()
ExecutionState
for this job vertex.StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.