| 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.