org.apache.tez.dag.library.vertexmanager

Class ShuffleVertexManager.CustomShuffleEdgeManager

java.lang.Object

org.apache.tez.dag.api.EdgeManagerPlugin

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

Enclosing class:

ShuffleVertexManager

public static class ShuffleVertexManager.CustomShuffleEdgeManager
extends org.apache.tez.dag.api.EdgeManagerPlugin

Constructor Summary

Constructors

Constructor and Description
ShuffleVertexManager.CustomShuffleEdgeManager(org.apache.tez.dag.api.EdgeManagerPluginContext context)

Method Summary

Methods

Modifier and Type	Method and Description
int	getNumDestinationConsumerTasks(int sourceTaskIndex)
int	getNumDestinationTaskPhysicalInputs(int destinationTaskIndex)
int	getNumSourceTaskPhysicalOutputs(int sourceTaskIndex)
void	initialize()
void	routeDataMovementEventToDestination(org.apache.tez.runtime.api.events.DataMovementEvent event, int sourceTaskIndex, int sourceOutputIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)
int	routeInputErrorEventToSource(org.apache.tez.runtime.api.events.InputReadErrorEvent event, int destinationTaskIndex, int destinationFailedInputIndex)
void	routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)

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

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffleVertexManager.CustomShuffleEdgeManager

public ShuffleVertexManager.CustomShuffleEdgeManager(org.apache.tez.dag.api.EdgeManagerPluginContext context)

Method Detail

initialize

public void initialize()

Specified by:

initialize in class org.apache.tez.dag.api.EdgeManagerPlugin

getNumDestinationTaskPhysicalInputs

public int getNumDestinationTaskPhysicalInputs(int destinationTaskIndex)

Specified by:

getNumDestinationTaskPhysicalInputs in class org.apache.tez.dag.api.EdgeManagerPlugin

getNumSourceTaskPhysicalOutputs

public int getNumSourceTaskPhysicalOutputs(int sourceTaskIndex)

Specified by:

getNumSourceTaskPhysicalOutputs in class org.apache.tez.dag.api.EdgeManagerPlugin

routeDataMovementEventToDestination

public void routeDataMovementEventToDestination(org.apache.tez.runtime.api.events.DataMovementEvent event,
                                       int sourceTaskIndex,
                                       int sourceOutputIndex,
                                       Map<Integer,List<Integer>> destinationTaskAndInputIndices)

Specified by:

routeDataMovementEventToDestination in class org.apache.tez.dag.api.EdgeManagerPlugin

routeInputSourceTaskFailedEventToDestination

public void routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex,
                                                Map<Integer,List<Integer>> destinationTaskAndInputIndices)

Specified by:

routeInputSourceTaskFailedEventToDestination in class org.apache.tez.dag.api.EdgeManagerPlugin

routeInputErrorEventToSource

public int routeInputErrorEventToSource(org.apache.tez.runtime.api.events.InputReadErrorEvent event,
                               int destinationTaskIndex,
                               int destinationFailedInputIndex)

Specified by:

routeInputErrorEventToSource in class org.apache.tez.dag.api.EdgeManagerPlugin

getNumDestinationConsumerTasks

public int getNumDestinationConsumerTasks(int sourceTaskIndex)

Specified by:

getNumDestinationConsumerTasks in class org.apache.tez.dag.api.EdgeManagerPlugin