public static class ShuffleVertexManager.CustomShuffleEdgeManager
extends org.apache.tez.dag.api.EdgeManagerPlugin
Constructor and Description |
---|
ShuffleVertexManager.CustomShuffleEdgeManager(org.apache.tez.dag.api.EdgeManagerPluginContext context) |
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) |
public ShuffleVertexManager.CustomShuffleEdgeManager(org.apache.tez.dag.api.EdgeManagerPluginContext context)
public void initialize()
initialize
in class org.apache.tez.dag.api.EdgeManagerPlugin
public int getNumDestinationTaskPhysicalInputs(int destinationTaskIndex)
getNumDestinationTaskPhysicalInputs
in class org.apache.tez.dag.api.EdgeManagerPlugin
public int getNumSourceTaskPhysicalOutputs(int sourceTaskIndex)
getNumSourceTaskPhysicalOutputs
in class org.apache.tez.dag.api.EdgeManagerPlugin
public void routeDataMovementEventToDestination(org.apache.tez.runtime.api.events.DataMovementEvent event, int sourceTaskIndex, int sourceOutputIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)
routeDataMovementEventToDestination
in class org.apache.tez.dag.api.EdgeManagerPlugin
public void routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)
routeInputSourceTaskFailedEventToDestination
in class org.apache.tez.dag.api.EdgeManagerPlugin
public int routeInputErrorEventToSource(org.apache.tez.runtime.api.events.InputReadErrorEvent event, int destinationTaskIndex, int destinationFailedInputIndex)
routeInputErrorEventToSource
in class org.apache.tez.dag.api.EdgeManagerPlugin
public int getNumDestinationConsumerTasks(int sourceTaskIndex)
getNumDestinationConsumerTasks
in class org.apache.tez.dag.api.EdgeManagerPlugin
Copyright © 2015 Apache Software Foundation. All rights reserved.