org.apache.reef.wake.remote.impl

Class RemoteEventDecoder<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

Decoder<RemoteEvent<T>>

public class RemoteEventDecoder<T>
extends Object
implements Decoder<RemoteEvent<T>>

Remote event decoder using the WakeMessage protocol buffer.

Constructor Summary

Constructors

Constructor and Description
RemoteEventDecoder(Decoder<T> decoder) Constructs a remote event decoder.

Method Summary

Methods

Modifier and Type	Method and Description
RemoteEvent<T>	decode(byte[] data) Decodes a remote event from the byte array data.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteEventDecoder

public RemoteEventDecoder(Decoder<T> decoder)

Constructs a remote event decoder.

Parameters:

decoder - the decoder of the event

Method Detail

decode

public RemoteEvent<T> decode(byte[] data)

Decodes a remote event from the byte array data.

Specified by:

decode in interface Decoder<RemoteEvent<T>>

Parameters:

data - the byte array data

Returns:

a remote event object

Throws:

RemoteRuntimeException