| Package | Description | 
|---|---|
| org.apache.reef.wake.remote.impl | 
| Modifier and Type | Method and Description | 
|---|---|
RemoteEvent<T> | 
RemoteEventDecoder.decode(byte[] data)
Decodes a remote event from the byte array data 
 | 
RemoteEvent<T> | 
RemoteEventCodec.decode(byte[] data)
Decodes a remote event object from the bytes 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> EventHandler<RemoteEvent<T>> | 
RemoteSenderStage.getHandler()
Returns a new remote sender event handler 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
RemoteEventComparator.compare(RemoteEvent<T> o1,
              RemoteEvent<T> o2)  | 
int | 
RemoteEventComparator.compare(RemoteEvent<T> o1,
              RemoteEvent<T> o2)  | 
byte[] | 
RemoteEventCodec.encode(RemoteEvent<T> obj)
Encodes the remote event object to bytes 
 | 
byte[] | 
RemoteEventEncoder.encode(RemoteEvent<T> obj)
Encodes the remote event object to bytes 
 | 
| Constructor and Description | 
|---|
OrderedRemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
                                                    EventHandler<Throwable> errorHandler)
Constructs a ordered remote receiver stage 
 | 
ProxyEventHandler(RemoteIdentifier myId,
                                  RemoteIdentifier remoteId,
                                  String remoteSinkName,
                                  EventHandler<RemoteEvent<T>> handler,
                                  RemoteSeqNumGenerator seqGen)
Constructs a proxy event handler 
 | 
RemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
                                      EventHandler<Throwable> errorHandler,
                                      int numThreads)
Constructs a remote receiver stage 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.