Package org.apache.reef.wake.remote.impl

Implementations for Wake's remote communication.

See: Description

Class Summary

Class	Description
ByteCodec	Codec that performs identity transformation on bytes.
ConnectFutureTask<T>	FutureTask for network connection.
DefaultRemoteIdentifierFactoryImplementation	A default implementation for RemoteIdentifierFactory interface.
DefaultRemoteManagerImplementation	Default remote manager implementation.
DefaultTransportEStage	A default event-based message transporting stage for both client and server.
MultiCodec<T>	Codec using the WakeTuple protocol buffer.
MultiDecoder<T>	Decoder using the WakeTuple protocol buffer.
MultiEncoder<T>	Encoder using the WakeTuple protocol buffer.
ObjectSerializableCodec<T>	Codec that uses Java serialization.
OrderedRemoteReceiverStage	Receive incoming events and dispatch to correct handlers in order.
ProxyEventHandler<T>	Proxy of the event handler that runs remotely.
RemoteEvent<T>	Event that are exchanged across process boundaries.
RemoteEventCodec<T>	Codec of the event sent remotely.
RemoteEventComparator<T>	Comparator for the remote event.
RemoteEventDecoder<T>	Remote event decoder using the WakeMessage protocol buffer.
RemoteEventEncoder<T>	Remote event encoder using the WakeMessage protocol buffer.
RemoteReceiverStage	Receive incoming events and dispatch to correct handlers.
RemoteSenderStage	Stage to manage resources related to sending event remotely.
RemoteSeqNumGenerator	Generates the sequence number for remote messages per destination.
SocketRemoteIdentifier	Remote identifier based on a socket address.
StringCodec	Codec that encodes/decodes a string.
Subscription<T>	Deprecated [REEF-1544] Prefer using SubscriptionHandler and the corresponding handlers instead of the Subscription class.
TransportEvent	Event sent from a remote node.
Tuple2<T1,T2>	Tuple with two values.

Package org.apache.reef.wake.remote.impl Description

Implementations for Wake's remote communication.