org.apache.tez.runtime.api.events

Class InputDataInformationEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.InputDataInformationEvent

@InterfaceStability.Unstable
 @InterfaceAudience.Public
public final class InputDataInformationEvent
extends Event

Events used by InputInitializer implementations to provide the user payload for individual tasks running as part of the Vertex for which an Initial Input has been configured. This event is used by InputInitialziers to configure tasks belonging to a Vertex. The event may be processed by a @link VertexManagerPlugin before being sent to tasks. A InputInitializer may send Events with or without a serialized user payload. Events, after being processed by a VertexManagerPlugin, must contain the payload in a serialized form.

Method Summary

Modifier and Type	Method and Description
static InputDataInformationEvent	createWithObjectPayload(int srcIndex, Object userPayloadDeserialized)
static InputDataInformationEvent	createWithSerializedPath(int srcIndex, String serializedPath)
static InputDataInformationEvent	createWithSerializedPayload(int srcIndex, ByteBuffer userPayload) Provide a serialized form of the payload
Object	getDeserializedUserPayload()
String	getSerializedPath()
int	getSourceIndex()
int	getTargetIndex()
ByteBuffer	getUserPayload()
void	setTargetIndex(int target)
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

createWithSerializedPayload

public static InputDataInformationEvent createWithSerializedPayload(int srcIndex,
                                                                    ByteBuffer userPayload)

Provide a serialized form of the payload

Parameters:

srcIndex - the src index

userPayload - the serialized payload

createWithObjectPayload

public static InputDataInformationEvent createWithObjectPayload(int srcIndex,
                                                                Object userPayloadDeserialized)

createWithSerializedPath

public static InputDataInformationEvent createWithSerializedPath(int srcIndex,
                                                                 String serializedPath)

getSourceIndex

public int getSourceIndex()

getTargetIndex

public int getTargetIndex()

setTargetIndex

public void setTargetIndex(int target)

getSerializedPath

public String getSerializedPath()

getUserPayload

public ByteBuffer getUserPayload()

getDeserializedUserPayload

public Object getDeserializedUserPayload()

toString

public String toString()

Overrides:

toString in class Object