org.apache.reef.wake.remote.impl

Class MultiDecoder<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

Decoder<T>

public class MultiDecoder<T>
extends Object
implements Decoder<T>

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

Constructor Summary

Constructors

Constructor and Description
MultiDecoder(Map<Class<? extends T>,Decoder<? extends T>> clazzToDecoderMap) Constructs a decoder that decodes bytes based on the class name.

Method Summary

Methods

Modifier and Type	Method and Description
T	decode(byte[] data) Decodes byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiDecoder

public MultiDecoder(Map<Class<? extends T>,Decoder<? extends T>> clazzToDecoderMap)

Constructs a decoder that decodes bytes based on the class name.

Parameters:

clazzToDecoderMap - a map of decoder for class

Method Detail

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