Package org.apache.flink.runtime.executiongraph

Class ArchivedExecutionJobVertex

java.lang.Object

org.apache.flink.runtime.executiongraph.ArchivedExecutionJobVertex

All Implemented Interfaces:

Serializable, AccessExecutionJobVertex

public class ArchivedExecutionJobVertex
extends Object
implements AccessExecutionJobVertex, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices, JobVertexID id, String name, int parallelism, int maxParallelism, SlotSharingGroup slotSharingGroup, ResourceProfile resourceProfile, StringifiedAccumulatorResult[] archivedUserAccumulators)
ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ArchivedExecutionJobVertex

public ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex)

ArchivedExecutionJobVertex

public ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
                                  JobVertexID id,
                                  String name,
                                  int parallelism,
                                  int maxParallelism,
                                  SlotSharingGroup slotSharingGroup,
                                  ResourceProfile resourceProfile,
                                  StringifiedAccumulatorResult[] archivedUserAccumulators)

Method Detail

getName

public String getName()

Description copied from interface: AccessExecutionJobVertex

Returns the name for this job vertex.

Specified by:

getName in interface AccessExecutionJobVertex

Returns:

name for this job vertex.

getParallelism

public int getParallelism()

Description copied from interface: AccessExecutionJobVertex

Returns the parallelism for this job vertex.

Specified by:

getParallelism in interface AccessExecutionJobVertex

Returns:

parallelism for this job vertex.

getMaxParallelism

public int getMaxParallelism()

Description copied from interface: AccessExecutionJobVertex

Returns the max parallelism for this job vertex.

Specified by:

getMaxParallelism in interface AccessExecutionJobVertex

Returns:

max parallelism for this job vertex.

getSlotSharingGroup

public SlotSharingGroup getSlotSharingGroup()

Description copied from interface: AccessExecutionJobVertex

Returns the slot sharing group for this job vertex.

Specified by:

getSlotSharingGroup in interface AccessExecutionJobVertex

Returns:

slot sharing group for this job vertex.

getResourceProfile

public ResourceProfile getResourceProfile()

Description copied from interface: AccessExecutionJobVertex

Returns the resource profile for this job vertex.

Specified by:

getResourceProfile in interface AccessExecutionJobVertex

Returns:

resource profile for this job vertex.

getJobVertexId

public JobVertexID getJobVertexId()

Description copied from interface: AccessExecutionJobVertex

Returns the JobVertexID for this job vertex.

Specified by:

getJobVertexId in interface AccessExecutionJobVertex

Returns:

JobVertexID for this job vertex.

getTaskVertices

public ArchivedExecutionVertex[] getTaskVertices()

Description copied from interface: AccessExecutionJobVertex

Returns all execution vertices for this job vertex.

Specified by:

getTaskVertices in interface AccessExecutionJobVertex

Returns:

all execution vertices for this job vertex

getAggregateState

public ExecutionState getAggregateState()

Description copied from interface: AccessExecutionJobVertex

Returns the aggregated ExecutionState for this job vertex.

Specified by:

getAggregateState in interface AccessExecutionJobVertex

Returns:

aggregated state for this job vertex

getAggregatedUserAccumulatorsStringified

public StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()

Description copied from interface: AccessExecutionJobVertex

Returns the aggregated user-defined accumulators as strings.

Specified by:

getAggregatedUserAccumulatorsStringified in interface AccessExecutionJobVertex

Returns:

aggregated user-defined accumulators as strings.