Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Group Communication operator used to receive and reduce messages. More...
Inherits Org.Apache.REEF.Network.Group.Operators.IGroupCommOperator< T >.
Inherited by Org.Apache.REEF.Network.Group.Operators.Impl.ReduceReceiver< T >.
Public Member Functions | |
T | Reduce () |
Receives messages sent by all ReduceSenders and aggregates them using the specified IReduceFunction. More... | |
Properties | |
IReduceFunction< T > | ReduceFunction [get] |
Returns the class used to reduce incoming messages sent by ReduceSenders. More... | |
Properties inherited from Org.Apache.REEF.Network.Group.Operators.IGroupCommOperator< T > | |
string | OperatorName [get] |
The operator name. More... | |
string | GroupName [get] |
The name of the operator's CommunicationGroup. More... | |
int | Version [get] |
The operator version number. More... | |
Group Communication operator used to receive and reduce messages.
T | The message type |
T Org.Apache.REEF.Network.Group.Operators.IReduceReceiver< T >.Reduce | ( | ) |
Receives messages sent by all ReduceSenders and aggregates them using the specified IReduceFunction.
Implemented in Org.Apache.REEF.Network.Group.Operators.Impl.ReduceReceiver< T >.
|
get |
Returns the class used to reduce incoming messages sent by ReduceSenders.