| Package | Description | 
|---|---|
| org.apache.tez.dag.api | |
| org.apache.tez.runtime.api.events | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EdgeManagerPluginOnDemand.routeDataMovementEventToDestination(DataMovementEvent event,
                                   int sourceTaskIndex,
                                   int sourceOutputIndex,
                                   Map<Integer,List<Integer>> destinationTaskAndInputIndices)
Return the routing information to inform consumers about the source task
 output that is now available. 
 | 
abstract void | 
EdgeManagerPlugin.routeDataMovementEventToDestination(DataMovementEvent event,
                                   int sourceTaskIndex,
                                   int sourceOutputIndex,
                                   Map<Integer,List<Integer>> destinationTaskAndInputIndices)
Return the routing information to inform consumers about the source task
 output that is now available. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static DataMovementEvent | 
DataMovementEvent.create(int sourceIndex,
      ByteBuffer userPayload)
User Event constructor for  
Outputs | 
| Modifier and Type | Method and Description | 
|---|---|
Iterable<DataMovementEvent> | 
CompositeDataMovementEvent.getEvents()  | 
Copyright © 2021 Apache Software Foundation. All rights reserved.