Package | Description |
---|---|
org.apache.reef.io.network.group.api.operators |
Provides the interfaces for MPI style group communication operations.
|
org.apache.reef.io.network.group.api.task |
Elastic Group Communications Task-side API Interfaces.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
GroupCommOperator.initialize() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorTopology.initialize() |
byte[] |
OperatorTopology.recvFromChildren() |
<T> T |
OperatorTopology.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
byte[] |
OperatorTopology.recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopology.sendToChildren(byte[] data,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopology.sendToChildren(Map<String,byte[]> dataMap,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopology.sendToParent(byte[] encode,
ReefNetworkGroupCommProtos.GroupCommMessage.Type reduce) |
Modifier and Type | Method and Description |
---|---|
void |
ScatterSender.initialize() |
void |
ScatterReceiver.initialize() |
void |
ReduceSender.initialize() |
void |
ReduceReceiver.initialize() |
void |
GatherSender.initialize() |
void |
GatherReceiver.initialize() |
void |
BroadcastSender.initialize() |
void |
BroadcastReceiver.initialize() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorTopologyImpl.initialize() |
byte[] |
OperatorTopologyImpl.recvFromChildren() |
<T> T |
OperatorTopologyImpl.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
byte[] |
OperatorTopologyImpl.recvFromParent(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopologyImpl.sendToChildren(byte[] data,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopologyImpl.sendToChildren(Map<String,byte[]> dataMap,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
void |
OperatorTopologyImpl.sendToParent(byte[] data,
ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.