org.apache.reef.wake.remote.impl

Class MultiCodec<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

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

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

Codec using the WakeTuple protocol buffer. (class name and bytes)

Constructor Summary

Constructors

Constructor and Description
MultiCodec(Map<Class<? extends T>,Codec<? extends T>> clazzToCodecMap) Constructs a codec that encodes/decodes an object to/from bytes based on the class name.

Method Summary

Modifier and Type	Method and Description
T	decode(byte[] data) Decodes byte array.
byte[]	encode(T obj) Encodes an object to a byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiCodec

public MultiCodec(Map<Class<? extends T>,Codec<? extends T>> clazzToCodecMap)

Constructs a codec that encodes/decodes an object to/from bytes based on the class name.

Parameters:

clazzToCodecMap - a map of codec for class

Method Detail

encode

public byte[] encode(T obj)

Encodes an object to a byte array.

Specified by:

encode in interface Encoder<T>

Parameters:

obj - object to be encoded

Returns:

a byte[] representation of the object

decode

public T decode(byte[] data)

Decodes byte array.

Specified by:

decode in interface Decoder<T>

Parameters:

data - class name and byte payload

Returns:

the decoded object