Uses of Interface
org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver

Packages that use CommunicationGroupDriver

Package	Description
org.apache.reef.io.network.group.api.driver	Elastic Group Communications Driver-side API Interfaces.
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.

Uses of CommunicationGroupDriver in org.apache.reef.io.network.group.api.driver

Methods in org.apache.reef.io.network.group.api.driver that return CommunicationGroupDriver

Modifier and Type	Method and Description
CommunicationGroupDriver	CommunicationGroupDriver.addBroadcast(Class<? extends Name<String>> operatorName, BroadcastOperatorSpec spec) Add the broadcast operator specified by the.
CommunicationGroupDriver	CommunicationGroupDriver.addGather(Class<? extends Name<String>> operatorName, GatherOperatorSpec spec) Add the gather operator specified by operatorName and spec.
CommunicationGroupDriver	CommunicationGroupDriver.addReduce(Class<? extends Name<String>> operatorName, ReduceOperatorSpec spec) Add the reduce operator specified by the.
CommunicationGroupDriver	CommunicationGroupDriver.addScatter(Class<? extends Name<String>> operatorName, ScatterOperatorSpec spec) Add the scatter operator specified by operatorName and spec.
CommunicationGroupDriver	GroupCommDriver.newCommunicationGroup(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut) Create a new communication group with the specified name, topology implementation, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.
CommunicationGroupDriver	GroupCommDriver.newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks) Create a new communication group with the specified name.
CommunicationGroupDriver	GroupCommDriver.newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks, int customFanOut) Create a new communication group with the specified name, the minimum number of tasks needed in this group before communication can start, and a custom fanOut.

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

Classes in org.apache.reef.io.network.group.impl.driver that implement CommunicationGroupDriver

Modifier and Type	Class and Description
class	CommunicationGroupDriverImpl

Methods in org.apache.reef.io.network.group.impl.driver that return CommunicationGroupDriver

Modifier and Type	Method and Description
CommunicationGroupDriver	CommunicationGroupDriverImpl.addBroadcast(Class<? extends Name<String>> operatorName, BroadcastOperatorSpec spec)
CommunicationGroupDriver	CommunicationGroupDriverImpl.addGather(Class<? extends Name<String>> operatorName, GatherOperatorSpec spec)
CommunicationGroupDriver	CommunicationGroupDriverImpl.addReduce(Class<? extends Name<String>> operatorName, ReduceOperatorSpec spec)
CommunicationGroupDriver	CommunicationGroupDriverImpl.addScatter(Class<? extends Name<String>> operatorName, ScatterOperatorSpec spec)
CommunicationGroupDriver	CommunicationGroupDriverFactory.getNewInstance(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, int numberOfTasks, int customFanOut) Deprecated. in 0.14. Instantiates a new CommunicationGroupDriver instance.
CommunicationGroupDriver	CommunicationGroupDriverFactory.getNewInstance(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut) Instantiates a new CommunicationGroupDriver instance.
CommunicationGroupDriver	GroupCommDriverImpl.newCommunicationGroup(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut)
CommunicationGroupDriver	GroupCommDriverImpl.newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks)
CommunicationGroupDriver	GroupCommDriverImpl.newCommunicationGroup(Class<? extends Name<String>> groupName, int numberOfTasks, int customFanOut)