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.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.config |
Group Communication Operator Specifications.
|
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 | Class and Description |
---|---|
class |
LineSearchReduceFunction
Reduce function implementing line search.
|
class |
LossAndGradientReduceFunction
Loss and gradient reduce function.
|
Modifier and Type | Class and Description |
---|---|
class |
ModelReceiveAckReduceFunction
Reduce function for model receive acknowledgement.
|
Modifier and Type | Method and Description |
---|---|
Reduce.ReduceFunction<T> |
ReduceScatter.getReduceFunction()
get
Reduce.ReduceFunction configured. |
Reduce.ReduceFunction<T> |
Reduce.Receiver.getReduceFunction()
The reduce function to be applied on the set of received values.
|
Reduce.ReduceFunction<T> |
Reduce.Sender.getReduceFunction()
The
Reduce.ReduceFunction to be applied on the set of received values. |
Reduce.ReduceFunction<T> |
AllReduce.getReduceFunction()
Get the
Reduce.ReduceFunction configured. |
Modifier and Type | Method and Description |
---|---|
<T> T |
OperatorTopologyStruct.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
<T> T |
OperatorTopology.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Reduce.ReduceFunction> |
ReduceOperatorSpec.getRedFuncClass() |
Modifier and Type | Method and Description |
---|---|
ReduceOperatorSpec.Builder |
ReduceOperatorSpec.Builder.setReduceFunctionClass(Class<? extends Reduce.ReduceFunction> redFuncClass) |
Constructor and Description |
---|
ReduceOperatorSpec(String receiverId,
Class<? extends Codec> dataCodecClass,
Class<? extends Reduce.ReduceFunction> redFuncClass) |
Modifier and Type | Method and Description |
---|---|
Reduce.ReduceFunction<T> |
ReduceSender.getReduceFunction() |
Reduce.ReduceFunction<T> |
ReduceReceiver.getReduceFunction() |
Constructor and Description |
---|
ReduceReceiver(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
Reduce.ReduceFunction<T> reduceFunction,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
ReduceSender(String groupName,
String operName,
String selfId,
Codec<T> dataCodec,
Reduce.ReduceFunction<T> reduceFunction,
String driverId,
int version,
CommGroupNetworkHandler commGroupNetworkHandler,
NetworkService<GroupCommunicationMessage> netService,
CommunicationGroupServiceClient commGroupClient) |
Modifier and Type | Method and Description |
---|---|
<T> T |
OperatorTopologyStructImpl.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
<T> T |
OperatorTopologyImpl.recvFromChildren(Reduce.ReduceFunction<T> redFunc,
Codec<T> dataCodec) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.