org.apache.pig.backend.hadoop.executionengine.tez.runtime

Class PigGraceShuffleVertexManager

java.lang.Object

org.apache.tez.dag.api.VertexManagerPlugin

org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigGraceShuffleVertexManager

public class PigGraceShuffleVertexManager
extends org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager.CustomShuffleEdgeManager, org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager.ShuffleVertexManagerConfigBuilder

Field Summary

Fields inherited from class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

TEZ_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE, TEZ_SHUFFLE_VERTEX_MANAGER_DESIRED_TASK_INPUT_SIZE_DEFAULT, TEZ_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL, TEZ_SHUFFLE_VERTEX_MANAGER_ENABLE_AUTO_PARALLEL_DEFAULT, TEZ_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION, TEZ_SHUFFLE_VERTEX_MANAGER_MAX_SRC_FRACTION_DEFAULT, TEZ_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION, TEZ_SHUFFLE_VERTEX_MANAGER_MIN_SRC_FRACTION_DEFAULT, TEZ_SHUFFLE_VERTEX_MANAGER_MIN_TASK_PARALLELISM, TEZ_SHUFFLE_VERTEX_MANAGER_MIN_TASK_PARALLELISM_DEFAULT

Constructor Summary

Constructors

Constructor and Description
PigGraceShuffleVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Summary

Modifier and Type	Method and Description
void	initialize()
void	onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)

Methods inherited from class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

createConfigBuilder, onRootVertexInitialized, onSourceTaskCompleted, onVertexManagerEventReceived, onVertexStarted

Methods inherited from class org.apache.tez.dag.api.VertexManagerPlugin

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

PigGraceShuffleVertexManager

public PigGraceShuffleVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Detail

initialize

public void initialize()

Overrides:

initialize in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager

onVertexStateUpdated

public void onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)

Overrides:

onVertexStateUpdated in class org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager