org.apache.tez.dag.api

Class EdgeManagerPluginOnDemand.EventRouteMetadata

java.lang.Object

org.apache.tez.dag.api.EdgeManagerPluginOnDemand.EventRouteMetadata

Enclosing class:

EdgeManagerPluginOnDemand

public static class EdgeManagerPluginOnDemand.EventRouteMetadata
extends Object

Class to provide routing metadata for Events to be routed between producer and consumer tasks. The routing data enabled the system to send the event from the producer task output to the consumer task input

Method Summary

Methods

Modifier and Type	Method and Description
static 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	create(int numEvents, int[] targetIndices, int[] sourceIndices) Create an EdgeManagerPluginOnDemand.EventRouteMetadata that will create numEvents copies of the Event to be routed.
int	getNumEvents() Get the number of copies of the event to be routed
int[]	getSourceIndices() Get the source output indices
int[]	getTargetIndices() Get the target input indices

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static EdgeManagerPluginOnDemand.EventRouteMetadata create(int numEvents,
                                                  int[] targetIndices)

Create an EdgeManagerPluginOnDemand.EventRouteMetadata that will create numEvents copies of the Event to be routed. Use this to create EdgeManagerPluginOnDemand.EventRouteMetadata for DataMovementEvents or InputFailedEvents where the target input indices must be specified to route those events. Typically numEvents would be 1 for these events.

Parameters:

numEvents - Number of copies of the event to be routed

targetIndices - Target input indices. The array length must match the number of events specified when creating the EdgeManagerPluginOnDemand.EventRouteMetadata object

Returns:

EdgeManagerPluginOnDemand.EventRouteMetadata

create

public static EdgeManagerPluginOnDemand.EventRouteMetadata create(int numEvents,
                                                  int[] targetIndices,
                                                  int[] sourceIndices)

Create an EdgeManagerPluginOnDemand.EventRouteMetadata that will create numEvents copies of the Event to be routed. Use this to create EdgeManagerPluginOnDemand.EventRouteMetadata for CompositeDataMovementEvent where the target input indices and source output indices must be specified to route those events. Typically numEvents would be 1 for these events.

Parameters:

numEvents - Number of copies of the event to be routed

targetIndices - Target input indices. The array length must match the number of events specified when creating the EdgeManagerPluginOnDemand.EventRouteMetadata object

sourceIndices - Source output indices. The array length must match the number of events specified when creating the EdgeManagerPluginOnDemand.EventRouteMetadata object

Returns:

EdgeManagerPluginOnDemand.EventRouteMetadata

getNumEvents

public int getNumEvents()

Get the number of copies of the event to be routed

Returns:

Number of copies

getTargetIndices

@Nullable
public int[] getTargetIndices()

Get the target input indices

Returns:

Target input indices

getSourceIndices

@Nullable
public int[] getSourceIndices()

Get the source output indices

Returns:

Source output indices