Package | Description |
---|---|
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
org.apache.reef.io.network.group.impl.utils |
Utilities for group communication.
|
org.apache.reef.io.network.impl |
TODO: Document.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionService.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId)
Registers an instance of ConnectionFactory corresponding to the connectionFactoryId.
|
<T> ConnectionFactory<T> |
NetworkConnectionService.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId)
Registers an instance of ConnectionFactory corresponding to the connectionFactoryId.
|
Modifier and Type | Method and Description |
---|---|
void |
GroupCommNetworkHandlerImpl.onNext(Message<GroupCommunicationMessage> mesg) |
Modifier and Type | Method and Description |
---|---|
static GroupCommunicationMessage |
Utils.getGCM(Message<GroupCommunicationMessage> msg)
Extract a group communication message object from a message.
|
Modifier and Type | Class and Description |
---|---|
class |
NSMessage<T>
Network service message that implements the Message interface.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId) |
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId) |
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.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.