|
Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Group Communication operator used to receive and reduce messages in pipelined fashion. More...
Inherits Org.Apache.REEF.Network.Group.Operators.IReduceReceiver< T >, and Org.Apache.REEF.Network.Group.Operators.IGroupCommOperatorInternal.
Public Member Functions | |
| T | Reduce () |
| Receives messages sent by all ReduceSenders and aggregates them using the specified IReduceFunction. More... | |
Properties | |
| string | OperatorName [get] |
| Returns the name of the reduce operator More... | |
| string | GroupName [get] |
| Returns the name of the operator's CommunicationGroup. More... | |
| int | Version [get] |
| Returns the operator version. More... | |
| IReduceFunction< T > | ReduceFunction [get] |
| Returns the class used to reduce incoming messages sent by ReduceSenders. More... | |
| IPipelineDataConverter< T > | PipelineDataConverter [get] |
| Returns the IPipelineDataConvert used to convert messages to pipeline form and vice-versa More... | |
Properties inherited from Org.Apache.REEF.Network.Group.Operators.IReduceReceiver< T > | |
| 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 in pipelined fashion.
| T | The message type |
|
inline |
Receives messages sent by all ReduceSenders and aggregates them using the specified IReduceFunction.
Implements Org.Apache.REEF.Network.Group.Operators.IReduceReceiver< T >.
|
get |
Returns the name of the operator's CommunicationGroup.
|
get |
Returns the name of the reduce operator
|
get |
Returns the IPipelineDataConvert used to convert messages to pipeline form and vice-versa
|
get |
Returns the class used to reduce incoming messages sent by ReduceSenders.
|
get |
Returns the operator version.
1.8.11