Apache REEF
0.16.0
Retainable Evaluator Execution Framework
|
Wrapper class to bind a specific instance of a message with the associated sequence number. More...
Inherits Org.Apache.REEF.Wake.Avro.IMessageInstance< T >.
Public Member Functions | |
MessageInstance (long sequence, T message) | |
Create a new instance of the (sequence number, message payload) pair. More... | |
Properties | |
long | Sequence [get] |
Get the sequence number of a message. More... | |
T | Message [get] |
Return the data payload of message instance. More... | |
Wrapper class to bind a specific instance of a message with the associated sequence number.
T | Message payload type. |
|
inline |
Create a new instance of the (sequence number, message payload) pair.
sequence | The message sequence number. |
message | The message payload. |
|
get |
Return the data payload of message instance.
|
get |
Get the sequence number of a message.