Package | Description |
---|---|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.ports |
TCP port providers.
|
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 |
---|---|
<T> RemoteManager |
RemoteManagerFactory.getInstance(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout,
LocalAddressProvider localAddressProvider,
TcpPortProvider tcpPortProvider)
The all-out constructor of DefaultRemoteManagerImplementation.
|
Modifier and Type | Class and Description |
---|---|
class |
RangeTcpPortProvider
A TcpPortProvider which gives out random ports in a range.
|
Modifier and Type | Method and Description |
---|---|
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 | Method and Description |
---|---|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.