org.apache.reef.io.network.group.impl

Class GroupCommunicationMessageCodec

java.lang.Object

org.apache.reef.io.network.group.impl.GroupCommunicationMessageCodec

All Implemented Interfaces:

StreamingCodec<GroupCommunicationMessage>, Codec<GroupCommunicationMessage>, Decoder<GroupCommunicationMessage>, Encoder<GroupCommunicationMessage>

public class GroupCommunicationMessageCodec
extends Object
implements StreamingCodec<GroupCommunicationMessage>

Codec for ReefNetworkGroupCommProtos.GroupCommMessage.

Constructor Summary

Constructors

Constructor and Description
GroupCommunicationMessageCodec()

Method Summary

Methods

Modifier and Type	Method and Description
GroupCommunicationMessage	decode(byte[] data) Decodes the given byte array into an object.
GroupCommunicationMessage	decodeFromStream(DataInputStream stream)
byte[]	encode(GroupCommunicationMessage msg) Encodes the given object into a Byte Array.
void	encodeToStream(GroupCommunicationMessage msg, DataOutputStream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupCommunicationMessageCodec

@Inject
public GroupCommunicationMessageCodec()

Method Detail

decode

public GroupCommunicationMessage decode(byte[] data)

Description copied from interface: Decoder

Decodes the given byte array into an object.

Specified by:

decode in interface Decoder<GroupCommunicationMessage>

Parameters:

data - the data to be decoded

Returns:

the decoded object

decodeFromStream

public GroupCommunicationMessage decodeFromStream(DataInputStream stream)

Specified by:

decodeFromStream in interface StreamingCodec<GroupCommunicationMessage>

encode

public byte[] encode(GroupCommunicationMessage msg)

Description copied from interface: Encoder

Encodes the given object into a Byte Array.

Specified by:

encode in interface Encoder<GroupCommunicationMessage>

Parameters:

msg - an object to be encoded

Returns:

a byte[] representation of the object

encodeToStream

public void encodeToStream(GroupCommunicationMessage msg,
                  DataOutputStream stream)

Specified by:

encodeToStream in interface StreamingCodec<GroupCommunicationMessage>