org.apache.reef.wake.remote.impl

Class ObjectSerializableCodec<T>

java.lang.Object

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

Type Parameters:

T - type

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