org.apache.tez.runtime.api.events

Class DataMovementEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.DataMovementEvent

@InterfaceAudience.Public
public final class DataMovementEvent
extends Event

Event used by user code to send information between tasks. An output can generate an Event of this type to sending information regarding output data ( such as URI for file-based output data, port info in case of streaming-based data transfers ) to the Input on the destination vertex.

Method Summary

Methods

Modifier and Type	Method and Description
static DataMovementEvent	create(ByteBuffer userPayload) Constructor for Processor-generated User Events
static DataMovementEvent	create(int sourceIndex, ByteBuffer userPayload) User Event constructor
int	getSourceIndex()
int	getTargetIndex()
ByteBuffer	getUserPayload()
int	getVersion()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static DataMovementEvent create(int sourceIndex,
                       ByteBuffer userPayload)

User Event constructor

Parameters:

sourceIndex - Index to identify the physical edge of the input/output that generated the event

userPayload - User Payload of the User Event

create

public static DataMovementEvent create(ByteBuffer userPayload)

Constructor for Processor-generated User Events

Parameters:

userPayload -

getUserPayload

public ByteBuffer getUserPayload()

getSourceIndex

public int getSourceIndex()

getTargetIndex

public int getTargetIndex()

getVersion

public int getVersion()

toString

public String toString()

Overrides:

toString in class Object