org.apache.reef.wake.remote.impl

Class ObjectSerializableCodec<T>

java.lang.Object

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

Type Parameters:

T -

All Implemented Interfaces:

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

public class ObjectSerializableCodec<T>
extends Object
implements Codec<T>

Codec that uses Java serialization

Constructor Summary

Constructors

Constructor and Description
ObjectSerializableCodec()

Method Summary

Methods

Modifier and Type	Method and Description
T	decode(byte[] buf) Decodes an object from the bytes
byte[]	encode(T obj) Encodes the object to bytes

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectSerializableCodec

@Inject
public ObjectSerializableCodec()

Method Detail

encode

public byte[] encode(T obj)

Encodes the object to bytes

Specified by:

encode in interface Encoder<T>

Parameters:

obj - the object

Returns:

bytes

Throws:

RemoteRuntimeException

decode

public T decode(byte[] buf)

Decodes an object from the bytes

Specified by:

decode in interface Decoder<T>

Parameters:

buf - the bytes

Returns:

an object

Throws:

RemoteRuntimeException