| 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.io.network.naming.serialization |
Contains naming serialization codecs.
|
| org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
| org.apache.reef.wake.impl |
Wake's implementation.
|
| org.apache.reef.wake.remote |
Wake's remote communication.
|
| org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
| Modifier and Type | Method and Description |
|---|---|
static Pair<TopologySimpleNode,List<Identifier>> |
TopologySerializer.decode(byte[] data,
IdentifierFactory ifac)
Recursively translate a byte array into a TopologySimpleNode and a list of task Identifiers.
|
| Constructor and Description |
|---|
CtrlMsgSender(IdentifierFactory idFac,
NetworkService<GroupCommunicationMessage> netService) |
| Modifier and Type | Method and Description |
|---|---|
IdentifierFactory |
NetworkService.getIdentifierFactory() |
| Constructor and Description |
|---|
BindNSToTask(NetworkService<?> ns,
IdentifierFactory idFac) |
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.
|
NSMessageCodec(Codec<T> codec,
IdentifierFactory factory)
Constructs a network service message codec.
|
UnbindNSFromTask(NetworkService<?> ns,
IdentifierFactory idFac) |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<IdentifierFactory> |
NameResolverConfiguration.IDENTIFIER_FACTORY
Identifier factory for NameClient.
|
static OptionalParameter<IdentifierFactory> |
NameServerConfiguration.NAME_SERVER_IDENTIFIER_FACTORY
Identifier factory for the name service.
|
| 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.
|
| Constructor and Description |
|---|
NamingLookupRequestCodec(IdentifierFactory factory)
Constructs a naming lookup request codec.
|
NamingLookupResponseCodec(IdentifierFactory factory)
Constructs a naming lookup response codec.
|
NamingRegisterRequestCodec(IdentifierFactory factory)
Constructs a naming registration request codec.
|
NamingUnregisterRequestCodec(IdentifierFactory factory)
Constructs a naming un-registration request codec.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StringIdentifierFactory
Factory that creates StringIdentifier.
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends Identifier> |
Utils.parseList(String ids,
IdentifierFactory factory)
Parse a string of multiple IDs.
|
static List<ComparableIdentifier> |
Utils.parseListCmp(String ids,
IdentifierFactory factory)
Deprecated.
in 0.14. Please use parseList instead.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultIdentifierFactory
Default remote identifier factory that creates a specific remote identifier
from a string representation
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
RemoteIdentifierFactory
Factory that creates a RemoteIdentifier.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultRemoteIdentifierFactoryImplementation
A default implementation for RemoteIdentifierFactory interface.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.