org.apache.reef.wake.remote.impl

Class ProxyEventHandler<T>

java.lang.Object

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

Type Parameters:

T - type

All Implemented Interfaces:

EventHandler<T>

public class ProxyEventHandler<T>
extends Object
implements EventHandler<T>

Proxy of the event handler that runs remotely.

Constructor Summary

Constructors

Constructor and Description
ProxyEventHandler(RemoteIdentifier myId, RemoteIdentifier remoteId, String remoteSinkName, EventHandler<RemoteEvent<T>> handler, RemoteSeqNumGenerator seqGen) Constructs a proxy event handler.

Method Summary

Methods

Modifier and Type	Method and Description
void	onNext(T event) Sends the event to the event handler running remotely.
String	toString() Returns a string representation of the object.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyEventHandler

public ProxyEventHandler(RemoteIdentifier myId,
                 RemoteIdentifier remoteId,
                 String remoteSinkName,
                 EventHandler<RemoteEvent<T>> handler,
                 RemoteSeqNumGenerator seqGen)

Constructs a proxy event handler.

Parameters:

myId - my identifier

remoteId - the remote identifier

remoteSinkName - the remote sink name

Throws:

RemoteRuntimeException

Method Detail

onNext

public void onNext(T event)

Sends the event to the event handler running remotely.

Specified by:

onNext in interface EventHandler<T>

Parameters:

event - the event

toString

public String toString()

Returns a string representation of the object.

Overrides:

toString in class Object

Returns:

a string representation of the object