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 (CancellationTokenSource cancellationSource=null) |
| 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... | |
Detailed Description
Group Communication operator used to receive and reduce messages.
- Template Parameters
-
T The message type
Member Function Documentation
◆ Reduce()
| T Org.Apache.REEF.Network.Group.Operators.IReduceReceiver< T >.Reduce | ( | CancellationTokenSource | cancellationSource = null | ) |
Receives messages sent by all ReduceSenders and aggregates them using the specified IReduceFunction.
- Parameters
-
cancellationSource The cancellation token for the data reading operation cancellation
- Returns
- The single aggregated data
Implemented in Org.Apache.REEF.Network.Group.Operators.Impl.ReduceReceiver< T >.
Property Documentation
◆ ReduceFunction
|
get |
Returns the class used to reduce incoming messages sent by ReduceSenders.
The documentation for this interface was generated from the following file:
- lang/cs/Org.Apache.REEF.Network/Group/Operators/IReduceReceiver.cs
