Uses of Class
org.apache.reef.io.network.impl.NetworkService

Packages that use NetworkService

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.group.impl.operators	Implementations for Group Communication Operators.
org.apache.reef.io.network.group.impl.task	Implementations for Elastic Group Communications Task-side API.
org.apache.reef.io.network.impl	TODO: Document.

Uses of NetworkService in org.apache.reef.io.network.group.impl.driver

Constructors in org.apache.reef.io.network.group.impl.driver with parameters of type NetworkService

Constructor and Description
CtrlMsgSender(IdentifierFactory idFac, NetworkService<GroupCommunicationMessage> netService)

Uses of NetworkService in org.apache.reef.io.network.group.impl.operators

Constructors in org.apache.reef.io.network.group.impl.operators with parameters of type NetworkService

Constructor and Description
BroadcastReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
BroadcastSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceSender(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ScatterReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterDecoder scatterDecoder)
ScatterSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterEncoder scatterEncoder)
Sender(NetworkService<GroupCommunicationMessage> netService)

Uses of NetworkService in org.apache.reef.io.network.group.impl.task

Constructors in org.apache.reef.io.network.group.impl.task with parameters of type NetworkService

Constructor and Description
CommunicationGroupClientImpl(String groupName, String taskId, String driverId, GroupCommNetworkHandler groupCommNetworkHandler, Set<String> operatorConfigs, ConfigurationSerializer configSerializer, NetworkService<GroupCommunicationMessage> netService) Deprecated. in 0.14. Use the private constructor that receives an injector as a parameter instead.
GroupCommClientImpl(Set<String> groupConfigs, String taskId, GroupCommNetworkHandler groupCommNetworkHandler, NetworkService<ReefNetworkGroupCommProtos.GroupCommMessage> netService, ConfigurationSerializer configSerializer) Deprecated. in 0.14. Use the other constructor that receives an injector as a parameter instead. The parameters taskId and netService can be removed from the other constructor when this constructor gets deleted.

Uses of NetworkService in org.apache.reef.io.network.impl

Constructors in org.apache.reef.io.network.impl with parameters of type NetworkService

Constructor and Description
BindNSToTask(NetworkService<?> ns, IdentifierFactory idFac)
NetworkServiceClosingHandler(NetworkService<?> networkService)
UnbindNSFromTask(NetworkService<?> ns, IdentifierFactory idFac)