org.apache.reef.wake.remote.impl

Class MultiEncoder<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

Encoder<T>

public class MultiEncoder<T>
extends Object
implements Encoder<T>

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

Constructor Summary

Constructors

Constructor and Description
MultiEncoder(Map<Class<? extends T>,Encoder<? extends T>> clazzToEncoderMap) Constructs an encoder that encodes an object to bytes based on the class name.

Method Summary

Modifier and Type	Method and Description
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

MultiEncoder

public MultiEncoder(Map<Class<? extends T>,Encoder<? extends T>> clazzToEncoderMap)

Constructs an encoder that encodes an object to bytes based on the class name.

Parameters:

clazzToEncoderMap - a map of encoder 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 - an object to be encoded

Returns:

a byte[] representation of the object