org.apache.reef.evaluator.context

Class ContextMessage

java.lang.Object

org.apache.reef.evaluator.context.ContextMessage

All Implemented Interfaces:

Message

public final class ContextMessage
extends Object
implements Message

Evaluator-side representation of a message sent from an Evaluator to a Driver.

Method Summary

Methods

Modifier and Type	Method and Description
static ContextMessage	from(String messageSourceID, byte[] theBytes)
byte[]	get() Message payload
String	getMessageSourceID()

Methods inherited from class java.lang.Object

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

Method Detail

from

public static ContextMessage from(String messageSourceID,
                  byte[] theBytes)

Parameters:

messageSourceID - The message's sourceID. This will be accessible in the Driver for routing.

theBytes - The actual content of the message, serialized into a byte[]

Returns:

a new EvaluatorMessage with the given content.

getMessageSourceID

public String getMessageSourceID()

Returns:

the message source identifier.

get

public byte[] get()

Description copied from interface: Message

Message payload

Specified by:

get in interface Message

Returns:

the message