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

Class TaskMessagePOJO

java.lang.Object

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

All Implemented Interfaces:

Numberable

public final class TaskMessagePOJO
extends Object
implements Numberable

DriverSide representation of TaskMessageProto.

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 task

getSourceId

public String getSourceId()

Returns:

the ID of the TaskMessageSource that sent the message.

getSequenceNumber

public long getSequenceNumber()

Specified by:

getSequenceNumber in interface Numberable

Returns:

the sequence number of a message TaskMessage#getSequenceNumber()