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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
FlatTopology
Implements a one level Tree Topology.
|
class |
TreeTopology
Implements a tree topology with the specified Fan Out.
|
Modifier and Type | Method and Description |
---|---|
Topology |
TopologyFactory.getNewInstance(Class<? extends Name<String>> operatorName,
Class<? extends Topology> topologyClass)
Instantiates a new Topology instance.
|
Modifier and Type | Method and Description |
---|---|
Topology |
TopologyFactory.getNewInstance(Class<? extends Name<String>> operatorName,
Class<? extends Topology> topologyClass)
Instantiates a new Topology instance.
|
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) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.