@InterfaceAudience.Public public class CompositeDataMovementEvent extends Event
DataMovementEvent
s 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.Modifier and Type | Field and Description |
---|---|
protected int |
count |
protected int |
sourceIndexStart |
protected ByteBuffer |
userPayload |
protected int |
version |
Modifier and Type | Method and Description |
---|---|
static CompositeDataMovementEvent |
create(int srcIndexStart,
int count,
ByteBuffer userPayload) |
DataMovementEvent |
expand(int sourceIndex,
int targetIndex)
Expand the
CompositeDataMovementEvent into a routable
DataMovementEvent by providing the source output index and the
target input index. |
int |
getCount() |
Iterable<DataMovementEvent> |
getEvents() |
int |
getSourceIndexStart() |
ByteBuffer |
getUserPayload() |
int |
getVersion() |
void |
setVersion(int version) |
protected final int sourceIndexStart
protected final int count
protected int version
protected final ByteBuffer userPayload
public static CompositeDataMovementEvent create(int srcIndexStart, int count, ByteBuffer userPayload)
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.@InterfaceAudience.Private public DataMovementEvent expand(int sourceIndex, int targetIndex)
CompositeDataMovementEvent
into a routable
DataMovementEvent
by providing the source output index and the
target input index.sourceIndex
- The index of the physical output represented by the
DataMovementEvent
targetIndex
- The index of the physical input to which the given
DataMovementEvent
should be routed.DataMovementEvent
created from the
CompositeDataMovementEvent
with indices specified by the
method parameterspublic int getSourceIndexStart()
public int getCount()
public ByteBuffer getUserPayload()
public void setVersion(int version)
public int getVersion()
public Iterable<DataMovementEvent> getEvents()
Copyright © 2016 Apache Software Foundation. All rights reserved.