Package | Description |
---|---|
org.apache.reef.io.network.group.impl.driver |
This package contains the implementation of the driver side of the
Group Communication Service using the tree/flat topology.
|
org.apache.reef.io.network.impl |
TODO: Document.
|
org.apache.reef.io.network.naming |
TODO: Document.
|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.address |
Local address resolution.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
Constructor and Description |
---|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut,
LocalAddressProvider localAddressProvider,
TransportFactory tpFactory,
NameServer nameService)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
Constructor and Description |
---|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
Constructor and Description |
---|
NameServerImpl(int port,
IdentifierFactory factory,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this or, better, NameServer, instead.
|
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 |
HostnameBasedLocalAddressProvider
A LocalAddressProvider that uses
Inet4Address.getLocalHost().getHostAddress() . |
class |
LegacyLocalAddressProvider
Deprecated.
in 0.14. Use HostnameBasedLocalAddressProvider instead
|
Constructor and Description |
---|
MessagingTransportFactory(LocalAddressProvider localAddressProvider)
Deprecated.
Have an instance injected instead.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.