org.apache.tez.dag.api.event

Class VertexStateUpdateParallelismUpdated

java.lang.Object

org.apache.tez.dag.api.event.VertexStateUpdate

org.apache.tez.dag.api.event.VertexStateUpdateParallelismUpdated

public class VertexStateUpdateParallelismUpdated
extends VertexStateUpdate

An event that is sent out when the parallelism of a vertex changes.

Constructor Summary

Constructors

Constructor and Description
VertexStateUpdateParallelismUpdated(String vertexName, int updatedParallelism, int previousParallelism)

Method Summary

Methods

Modifier and Type	Method and Description
int	getParallelism() Returns the new parallelism for the vertex
int	getPreviousParallelism() Returns the previous value of the parallelism

Methods inherited from class org.apache.tez.dag.api.event.VertexStateUpdate

getVertexName, getVertexState, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

VertexStateUpdateParallelismUpdated

public VertexStateUpdateParallelismUpdated(String vertexName,
                                   int updatedParallelism,
                                   int previousParallelism)

Method Detail

getParallelism

public int getParallelism()

Returns the new parallelism for the vertex

Returns:

the new parallelism

getPreviousParallelism

public int getPreviousParallelism()

Returns the previous value of the parallelism

Returns:

the previous parallelism