org.apache.tez.runtime.api.events

Class InputInitializerEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.InputInitializerEvent

@InterfaceStability.Unstable
@InterfaceAudience.Public
public class InputInitializerEvent
extends Event

An event that is routed to the specified InputInitializer. This can be used to send information/metadata to the InputInitializer

Method Summary

Methods

Modifier and Type	Method and Description
static InputInitializerEvent	create(String targetVertexName, String targetInputName, ByteBuffer eventPayload)
String	getTargetInputName() Get the input name to which this event is targeted
String	getTargetVertexName() Get the vertex name on which the targeted Input exists
ByteBuffer	getUserPayload() Get the actual user payload

Methods inherited from class java.lang.Object

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

Method Detail

create

public static InputInitializerEvent create(String targetVertexName,
                           String targetInputName,
                           ByteBuffer eventPayload)

Parameters:

targetVertexName - the vertex on which the targeted Input exists

targetInputName - the name of the input

eventPayload - the payload for the event. It is advisable to limit the size of the payload to a few KB at max

getTargetVertexName

public String getTargetVertexName()

Get the vertex name on which the targeted Input exists

Returns:

the vertex name

getTargetInputName

public String getTargetInputName()

Get the input name to which this event is targeted

Returns:

the input name

getUserPayload

public ByteBuffer getUserPayload()

Get the actual user payload

Returns:

a byte representation of the payload