Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static EdgeManagerPluginOnDemand.EventRouteMetadata |
EdgeManagerPluginOnDemand.EventRouteMetadata.create(int numEvents,
int[] targetIndices)
Create an
EdgeManagerPluginOnDemand.EventRouteMetadata that will create numEvents copies of
the Event to be routed. |
static EdgeManagerPluginOnDemand.EventRouteMetadata |
EdgeManagerPluginOnDemand.EventRouteMetadata.create(int numEvents,
int[] targetIndices,
int[] sourceIndices)
Create an
EdgeManagerPluginOnDemand.EventRouteMetadata that will create numEvents copies of
the Event to be routed. |
abstract EdgeManagerPluginOnDemand.EventRouteMetadata |
EdgeManagerPluginOnDemand.routeCompositeDataMovementEventToDestination(int sourceTaskIndex,
int destinationTaskIndex)
The method provides the
EdgeManagerPluginOnDemand.EventRouteMetadata to route a
CompositeDataMovementEvent produced by the given source task to the
given destination task. |
abstract EdgeManagerPluginOnDemand.EventRouteMetadata |
EdgeManagerPluginOnDemand.routeDataMovementEventToDestination(int sourceTaskIndex,
int sourceOutputIndex,
int destinationTaskIndex)
The method provides the
EdgeManagerPluginOnDemand.EventRouteMetadata to route a
DataMovementEvent produced by the given source task to the given
destination task. |
abstract EdgeManagerPluginOnDemand.EventRouteMetadata |
EdgeManagerPluginOnDemand.routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex,
int destinationTaskIndex)
The method provides the
EdgeManagerPluginOnDemand.EventRouteMetadata to route an
InputFailedEvent produced by the given source task to the given
destination task. |
Copyright © 2016 Apache Software Foundation. All rights reserved.