org.apache.reef.runtime.common.driver.evaluator.pojos

Class ContextMessagePOJO

java.lang.Object

org.apache.reef.runtime.common.driver.evaluator.pojos.ContextMessagePOJO

All Implemented Interfaces:

Numberable

public final class ContextMessagePOJO
extends Object
implements Numberable

DriverSide representation of ContextMessageProto.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	getMessage()
long	getSequenceNumber()
String	getSourceId()

Methods inherited from class java.lang.Object

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

Method Detail

getMessage

public byte[] getMessage()

Returns:

the serialized message from a context.

getSourceId

public String getSourceId()

Returns:

the ID of the ContextMessageSource that sent the message.

getSequenceNumber

public long getSequenceNumber()

Specified by:

getSequenceNumber in interface Numberable

Returns:

the sequence number of a message ContextMessage#getSequenceNumber()