org.apache.tez.runtime.api.events

Class CompositeDataMovementEvent

java.lang.Object

org.apache.tez.runtime.api.Event

org.apache.tez.runtime.api.events.CompositeDataMovementEvent

@InterfaceAudience.Public
public class CompositeDataMovementEvent
extends Event

A convenience class to specify multiple DataMovementEvents which share the same payload. A contiguous range of srcIndices can be specified. This event will NOT be seen by downstream Inputs - instead they will see DataMovementEvents which are generated based on the range specified in this event. This event should be used by an output which has the same payload for all of the Physical Outputs that it generates.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	count
protected int	sourceIndexStart
protected ByteBuffer	userPayload
protected int	version

Method Summary

Methods

Modifier and Type	Method and Description
static CompositeDataMovementEvent	create(int srcIndexStart, int count, ByteBuffer userPayload)
int	getCount()
Iterable<DataMovementEvent>	getEvents()
int	getSourceIndexStart()
ByteBuffer	getUserPayload()
int	getVersion()
void	setVersion(int version)

Methods inherited from class java.lang.Object

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

Field Detail

sourceIndexStart

protected final int sourceIndexStart

count

protected final int count

version

protected int version

userPayload

protected final ByteBuffer userPayload

Method Detail

create

public static CompositeDataMovementEvent create(int srcIndexStart,
                                int count,
                                ByteBuffer userPayload)

Parameters:

srcIndexStart - the startIndex of the physical source which generated the event (inclusive)

count - the number of physical sources represented by this event, starting from the srcIndexStart(non-inclusive)

userPayload - the common payload between all the events.

getSourceIndexStart

public int getSourceIndexStart()

getCount

public int getCount()

getUserPayload

public ByteBuffer getUserPayload()

setVersion

public void setVersion(int version)

getVersion

public int getVersion()

getEvents

public Iterable<DataMovementEvent> getEvents()