org.apache.reef.wake.remote.impl

Class RemoteEventCodec<T>

java.lang.Object

org.apache.reef.wake.remote.impl.RemoteEventCodec<T>

Type Parameters:

T - type

All Implemented Interfaces:

Codec<RemoteEvent<T>>, Decoder<RemoteEvent<T>>, Encoder<RemoteEvent<T>>

public class RemoteEventCodec<T>
extends Object
implements Codec<RemoteEvent<T>>

Codec of the event sent remotely

Constructor Summary

Constructors

Constructor and Description
RemoteEventCodec(Codec<T> codec) Constructs a remote event codec

Method Summary

Methods

Modifier and Type	Method and Description
RemoteEvent<T>	decode(byte[] data) Decodes a remote event object from the bytes
byte[]	encode(RemoteEvent<T> obj) Encodes the remote event object to bytes

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteEventCodec

public RemoteEventCodec(Codec<T> codec)

Constructs a remote event codec

Parameters:

codec - the codec for the event

Method Detail

encode

public byte[] encode(RemoteEvent<T> obj)

Encodes the remote event object to bytes

Specified by:

encode in interface Encoder<RemoteEvent<T>>

Parameters:

obj - the remote event object

Returns:

a byte[] representation of the object

decode

public RemoteEvent<T> decode(byte[] data)

Decodes a remote event object from the bytes

Specified by:

decode in interface Decoder<RemoteEvent<T>>

Parameters:

data - the byte array

Returns:

a remote event object