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 |
---|---|
TaskNode |
TaskNode.getParent() |
TaskNode |
TaskNode.successor() |
Modifier and Type | Method and Description |
---|---|
Iterable<TaskNode> |
TaskNode.getChildren() |
Modifier and Type | Method and Description |
---|---|
void |
TaskNode.addChild(TaskNode child) |
void |
TaskNode.removeChild(TaskNode taskNode) |
void |
TaskNode.setParent(TaskNode parent) |
void |
TaskNode.setSibling(TaskNode leaf) |
Modifier and Type | Class and Description |
---|---|
class |
TaskNodeImpl |
Modifier and Type | Method and Description |
---|---|
TaskNode |
TaskNodeImpl.getParent() |
TaskNode |
TaskNodeImpl.successor() |
Modifier and Type | Method and Description |
---|---|
Iterable<TaskNode> |
TaskNodeImpl.getChildren() |
Modifier and Type | Method and Description |
---|---|
void |
TaskNodeImpl.addChild(TaskNode child) |
static byte[] |
TopologySerializer.encode(TaskNode root)
Recursively encode TaskNodes of a Topology into a byte array.
|
void |
TaskNodeImpl.removeChild(TaskNode child) |
void |
TaskNodeImpl.setParent(TaskNode parent) |
void |
TaskNodeImpl.setSibling(TaskNode leaf) |
Modifier and Type | Method and Description |
---|---|
void |
TopologyUpdateWaitHandler.onNext(List<TaskNode> nodes) |
Constructor and Description |
---|
TaskNodeStatusImpl(Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operName,
String taskId,
TaskNode node) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.