Package | Description |
---|---|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
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[] |
RemoteEventEncoder.encode(RemoteEvent<T> obj)
Encodes the remote event object to bytes.
|
byte[] |
RemoteEventCodec.encode(RemoteEvent<T> obj)
Encodes the remote event object to bytes.
|
Constructor and Description |
---|
OrderedRemoteReceiverStage(EventHandler<RemoteEvent<byte[]>> handler,
EventHandler<Throwable> errorHandler)
Constructs an 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 © 2016 The Apache Software Foundation. All rights reserved.