org.apache.flink.runtime.executiongraph

Interface AccessExecutionJobVertex

All Known Implementing Classes:

ArchivedExecutionJobVertex, ExecutionJobVertex

public interface AccessExecutionJobVertex

Common interface for the runtime ExecutionJobVertex and ArchivedExecutionJobVertex.

Method Summary

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.

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.

getJobVertexId

JobVertexID getJobVertexId()

Returns the JobVertexID 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 aggregated ExecutionState 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.