Package | Description |
---|---|
org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
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.
|
Class and Description |
---|
GroupCommDriver
The driver side interface of Group Communication.
|
Class and Description |
---|
GroupCommDriver
The driver side interface of Group Communication.
|
Class and Description |
---|
CommunicationGroupDriver
The driver side interface of a Communication Group
Lets one add operators and tasks.
|
GroupCommDriver
The driver side interface of Group Communication.
|
TaskNode
A node in the Topology representing a Task on the driver.
|
Topology
A topology should implement the following
interface so that it can work with the
elastic group communication framework
Currently we have two implementations
1.
|
Class and Description |
---|
CommunicationGroupDriver
The driver side interface of a Communication Group
Lets one add operators and tasks.
|
GroupCommDriver
The driver side interface of Group Communication.
|
GroupCommServiceDriver |
TaskNode
A node in the Topology representing a Task on the driver.
|
TaskNodeStatus
Tracks the Status of the ctrl msgs sent to a
task node in the topology -
what msgs have been sent to this node and
what msgs have been ACKed as received by this node
Status of neighbors
This is used to see whether the local topology
of a Task is completely set-up
It also offers convenience methods for waiting
on receiving ACKs from the task.
|
Topology
A topology should implement the following
interface so that it can work with the
elastic group communication framework
Currently we have two implementations
1.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.