org.apache.hadoop.hive.ql.exec.tez
Class CustomPartitionEdge
java.lang.Object
org.apache.hadoop.hive.ql.exec.tez.CustomPartitionEdge
- All Implemented Interfaces:
- org.apache.tez.dag.api.EdgeManager
public class CustomPartitionEdge
- extends Object
- implements org.apache.tez.dag.api.EdgeManager
Method Summary |
int |
getNumDestinationConsumerTasks(int sourceTaskIndex,
int numDestinationTasks)
|
int |
getNumDestinationTaskPhysicalInputs(int numSourceTasks,
int destinationTaskIndex)
|
int |
getNumSourceTaskPhysicalOutputs(int numDestinationTasks,
int sourceTaskIndex)
|
void |
initialize(org.apache.tez.dag.api.EdgeManagerContext context)
|
void |
routeDataMovementEventToDestination(org.apache.tez.runtime.api.events.DataMovementEvent event,
int sourceTaskIndex,
int numDestinationTasks,
Map<Integer,List<Integer>> mapDestTaskIndices)
|
int |
routeInputErrorEventToSource(org.apache.tez.runtime.api.events.InputReadErrorEvent event,
int destinationTaskIndex)
|
void |
routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex,
int numDestinationTasks,
Map<Integer,List<Integer>> mapDestTaskIndices)
|
CustomPartitionEdge
public CustomPartitionEdge()
getNumDestinationTaskPhysicalInputs
public int getNumDestinationTaskPhysicalInputs(int numSourceTasks,
int destinationTaskIndex)
- Specified by:
getNumDestinationTaskPhysicalInputs
in interface org.apache.tez.dag.api.EdgeManager
getNumSourceTaskPhysicalOutputs
public int getNumSourceTaskPhysicalOutputs(int numDestinationTasks,
int sourceTaskIndex)
- Specified by:
getNumSourceTaskPhysicalOutputs
in interface org.apache.tez.dag.api.EdgeManager
getNumDestinationConsumerTasks
public int getNumDestinationConsumerTasks(int sourceTaskIndex,
int numDestinationTasks)
- Specified by:
getNumDestinationConsumerTasks
in interface org.apache.tez.dag.api.EdgeManager
initialize
public void initialize(org.apache.tez.dag.api.EdgeManagerContext context)
- Specified by:
initialize
in interface org.apache.tez.dag.api.EdgeManager
routeDataMovementEventToDestination
public void routeDataMovementEventToDestination(org.apache.tez.runtime.api.events.DataMovementEvent event,
int sourceTaskIndex,
int numDestinationTasks,
Map<Integer,List<Integer>> mapDestTaskIndices)
- Specified by:
routeDataMovementEventToDestination
in interface org.apache.tez.dag.api.EdgeManager
routeInputSourceTaskFailedEventToDestination
public void routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex,
int numDestinationTasks,
Map<Integer,List<Integer>> mapDestTaskIndices)
- Specified by:
routeInputSourceTaskFailedEventToDestination
in interface org.apache.tez.dag.api.EdgeManager
routeInputErrorEventToSource
public int routeInputErrorEventToSource(org.apache.tez.runtime.api.events.InputReadErrorEvent event,
int destinationTaskIndex)
- Specified by:
routeInputErrorEventToSource
in interface org.apache.tez.dag.api.EdgeManager
Copyright © 2014 The Apache Software Foundation. All rights reserved.