org.apache.reef.runtime.common.launch

Class REEFMessageCodec

java.lang.Object

org.apache.reef.runtime.common.launch.REEFMessageCodec

All Implemented Interfaces:

Codec<com.google.protobuf.GeneratedMessage>, Decoder<com.google.protobuf.GeneratedMessage>, Encoder<com.google.protobuf.GeneratedMessage>

public final class REEFMessageCodec
extends Object
implements Codec<com.google.protobuf.GeneratedMessage>

Codec for REEF's control flow messages.

Method Summary

Methods

Modifier and Type	Method and Description
com.google.protobuf.GeneratedMessage	decode(byte[] bytes) Decodes the given byte array into an object.
byte[]	encode(com.google.protobuf.GeneratedMessage msg) Encodes the given object into a Byte Array.

Methods inherited from class java.lang.Object

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

Method Detail

decode

public com.google.protobuf.GeneratedMessage decode(byte[] bytes)

Description copied from interface: Decoder

Decodes the given byte array into an object.

Specified by:

decode in interface Decoder<com.google.protobuf.GeneratedMessage>

Parameters:

bytes - the data to be decoded

Returns:

the decoded object

encode

public byte[] encode(com.google.protobuf.GeneratedMessage msg)

Description copied from interface: Encoder

Encodes the given object into a Byte Array.

Specified by:

encode in interface Encoder<com.google.protobuf.GeneratedMessage>

Parameters:

msg - an object to be encoded

Returns:

a byte[] representation of the object