Package | Description |
---|---|
org.apache.reef.io.network.impl |
TODO: Document.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
Modifier and Type | Method and Description |
---|---|
Transport |
NetworkService.getTransport() |
Constructor and Description |
---|
RemoteSenderStage(Encoder encoder,
Transport transport,
int numThreads)
Constructs a remote sender stage.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyMessagingTransport
Messaging transport implementation with Netty.
|
Modifier and Type | Method and Description |
---|---|
Transport |
MessagingTransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.