Uses of Class
org.apache.tez.runtime.api.events.DataMovementEvent

Packages that use DataMovementEvent

Package	Description
org.apache.tez.dag.api
org.apache.tez.runtime.api.events

Uses of DataMovementEvent in org.apache.tez.dag.api

Methods in org.apache.tez.dag.api with parameters of type DataMovementEvent

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.

Uses of DataMovementEvent in org.apache.tez.runtime.api.events

Methods in org.apache.tez.runtime.api.events that return DataMovementEvent

Modifier and Type	Method and Description
static DataMovementEvent	DataMovementEvent.create(ByteBuffer userPayload)
static DataMovementEvent	DataMovementEvent.create(int sourceIndex, ByteBuffer userPayload) User Event constructor for Outputs
static DataMovementEvent	DataMovementEvent.create(int sourceIndex, int targetIndex, int version, ByteBuffer userPayload)
DataMovementEvent	CompositeDataMovementEvent.expand(int sourceIndex, int targetIndex) Expand the CompositeDataMovementEvent into a routable DataMovementEvent by providing the source output index and the target input index.
DataMovementEvent	DataMovementEvent.makeCopy(int targetIndex) Make a routable copy of the DataMovementEvent by adding a target input index

Methods in org.apache.tez.runtime.api.events that return types with arguments of type DataMovementEvent

Modifier and Type	Method and Description
Iterable<DataMovementEvent>	CompositeDataMovementEvent.getEvents()