Package | Description |
---|---|
org.apache.reef.examples.suspend |
Suspend/resume demo.
|
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.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
Constructor and Description |
---|
Control(int port,
String taskId,
String command,
TransportFactory tpFactory) |
SuspendClientControl(int port,
TransportFactory tpFactory) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
MessagingTransportFactory
Factory that creates a messaging transport.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.