@InterfaceAudience.Public public final class DataMovementEvent extends Event
Modifier and Type | Method and Description |
---|---|
static DataMovementEvent |
create(ByteBuffer userPayload) |
static DataMovementEvent |
create(int sourceIndex,
ByteBuffer userPayload)
User Event constructor for
Output s |
static DataMovementEvent |
create(int sourceIndex,
int targetIndex,
int version,
ByteBuffer userPayload) |
int |
getSourceIndex() |
int |
getTargetIndex() |
ByteBuffer |
getUserPayload() |
int |
getVersion() |
DataMovementEvent |
makeCopy(int targetIndex)
Make a routable copy of the
DataMovementEvent by adding a target
input index |
void |
setTargetIndex(int targetIndex) |
void |
setVersion(int version) |
String |
toString() |
public static DataMovementEvent create(int sourceIndex, ByteBuffer userPayload)
Output
ssourceIndex
- Index to identify the physical edge of the input/output
that generated the eventuserPayload
- User Payload of the User Event@InterfaceAudience.Private public static DataMovementEvent create(ByteBuffer userPayload)
@InterfaceAudience.Private public static DataMovementEvent create(int sourceIndex, int targetIndex, int version, ByteBuffer userPayload)
@InterfaceAudience.Private public DataMovementEvent makeCopy(int targetIndex)
DataMovementEvent
by adding a target
input indextargetIndex
- The index of the physical input to which this
DataMovementEvent
should be routedDataMovementEvent
with the target input index
added to itpublic ByteBuffer getUserPayload()
public int getSourceIndex()
public int getTargetIndex()
@InterfaceAudience.Private public void setTargetIndex(int targetIndex)
public int getVersion()
@InterfaceAudience.Private public void setVersion(int version)
Copyright © 2016 Apache Software Foundation. All rights reserved.