org.apache.reef.examples.suspend

Class ObjectWritableCodec<T extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.reef.examples.suspend.ObjectWritableCodec<T>

Type Parameters:

T - Class derived from Hadoop Writable.

All Implemented Interfaces:

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

public class ObjectWritableCodec<T extends org.apache.hadoop.io.Writable>
extends Object
implements Codec<T>

Codec for Hadoop Writable object serialization.

Constructor Summary

Constructors

Constructor and Description
ObjectWritableCodec(Class<? extends T> clazz) Create a new codec for Hadoop Writables.

Method Summary

Methods

Modifier and Type	Method and Description
T	decode(byte[] buffer) Decode Hadoop Writable object from a byte array.
byte[]	encode(T writable) Encodes Hadoop Writable object into a byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectWritableCodec

public ObjectWritableCodec(Class<? extends T> clazz)

Create a new codec for Hadoop Writables.

Parameters:

clazz - we need it to invoke the class constructor.

Method Detail

encode

public byte[] encode(T writable)

Encodes Hadoop Writable object into a byte array.

Specified by:

encode in interface Encoder<T extends org.apache.hadoop.io.Writable>

Parameters:

writable - the object to encode.

Returns:

serialized object as byte array.

Throws:

RemoteRuntimeException - if serialization fails.

decode

public T decode(byte[] buffer)

Decode Hadoop Writable object from a byte array.

Specified by:

decode in interface Decoder<T extends org.apache.hadoop.io.Writable>

Parameters:

buffer - serialized version of the Writable object (as a byte array).

Returns:

a Writable object.

Throws:

RemoteRuntimeException - if deserialization fails.