Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Classes | |
class | AllErrorsTransientStrategy |
class | ByteCodec |
class | Channel |
Performs low level network IO operations between hosts More... | |
class | DefaultLocalAddressProvider |
The local address provider that provides the local IP address using NetworkUtils.LocalIPAddress. More... | |
class | DefaultRemoteManager |
Manages incoming and outgoing messages between remote hosts. More... | |
class | DefaultRemoteMessage |
class | IntCodec |
class | IPEndPointComparer |
Class to compare two IPEndPoint objects. | |
class | Link |
Represents an open connection between remote hosts More... | |
class | LoopbackLocalAddressProvider |
Provides the loopback address as the local address. More... | |
class | MultiCodec |
Codec that can encode and decode a class depending on the class type. More... | |
class | MultiDecoder |
Decoder using the WakeTuple protocol buffer (class name and bytes) More... | |
class | MultiEncoder |
Encoder using the WakeTuple protocol buffer (class name and bytes) More... | |
class | ObserverContainer |
Stores registered IObservers for DefaultRemoteManager. | |
class | RemoteConnectionRetryHandler |
Handles the retry logic to connect to remote endpoint | |
class | RemoteEvent |
class | RemoteEventCodec |
class | RemoteEventDecoder |
class | RemoteEventEncoder |
class | RemoteEventEndPoint |
class | RemoteEventStreamingCodec |
Writable remote event class | |
class | SocketRemoteIdentifier |
Remote identifier based on a socket address More... | |
class | StreamDataReader |
Class with functions to Read from stream More... | |
class | StreamDataWriter |
class | StreamingLink |
Represents an open connection between remote hosts. | |
class | StreamingRemoteManager |
Manages incoming and outgoing messages between remote hosts. | |
class | StreamingRemoteManagerFactory |
StreamingRemoteManagerFactory for StreamingRemoteManager. More... | |
class | StreamingTransportClient |
Establish connections to TransportServer for remote message passing | |
class | StreamingTransportServer |
Server to handle incoming remote messages. | |
class | StringCodec |
class | StringIdentifier |
class | StringIdentifierFactory |
class | TcpClientConnectionException |
Exception class for the case when Tcp Client connection fails after trying for some finite number of times. More... | |
class | TcpClientConnectionFactory |
Default implementation of ITcpClientFactory. More... | |
class | TransportClient |
Establish connections to TransportServer for remote message passing More... | |
class | TransportEvent |
class | TransportServer |
Server to handle incoming remote messages. More... | |