org.apache.reef.wake.remote.impl

Class RemoteEventEncoder<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

Encoder<RemoteEvent<T>>

public class RemoteEventEncoder<T>
extends Object
implements Encoder<RemoteEvent<T>>

Remote event encoder using the WakeMessage protocol buffer.

Constructor Summary

Constructors

Constructor and Description
RemoteEventEncoder(Encoder<T> encoder) Constructs a remote event encoder.

Method Summary

Modifier and Type	Method and Description
byte[]	encode(RemoteEvent<T> obj) Encodes the remote event object to bytes.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteEventEncoder

public RemoteEventEncoder(Encoder<T> encoder)

Constructs a remote event encoder.

Parameters:

encoder - the encoder of the event

Method Detail

encode

public byte[] encode(RemoteEvent<T> obj)

Encodes the remote event object to bytes.

Specified by:

encode in interface Encoder<RemoteEvent<T>>

Parameters:

obj - the remote event

Returns:

bytes

Throws:

RemoteRuntimeException