Apache REEF
0.16.0
Retainable Evaluator Execution Framework
|
Group Communication Operator used to send messages to be reduced by the ReduceReceiver. More...
Inherits Org.Apache.REEF.Network.Group.Operators.IGroupCommOperator< T >.
Inherited by Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.
Public Member Functions | |
void | Send (T data, CancellationTokenSource cancellationSource=null) |
Get reduced data from children, reduce with the data given, then sends reduced data to parent More... | |
Additional Inherited Members | |
![]() | |
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 send messages to be reduced by the ReduceReceiver.
T | The message type |
void Org.Apache.REEF.Network.Group.Operators.IReduceSender< T >.Send | ( | T | data, |
CancellationTokenSource | cancellationSource = null |
||
) |
Get reduced data from children, reduce with the data given, then sends reduced data to parent
data | The data to send |
cancellationSource | The cancellation token for the data reading operation cancellation |
Implemented in Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.