Apache REEF  0.16.0
Retainable Evaluator Execution Framework
Public Member Functions | Properties | List of all members
Org.Apache.REEF.Network.Group.Operators.Impl.ScatterReceiver< T > Class Template Reference

Group Communication operator used to receive a sublist of messages sent from the IScatterSender. More...

Inherits Org.Apache.REEF.Network.Group.Operators.IScatterReceiver< T >, and Org.Apache.REEF.Network.Group.Operators.IGroupCommOperatorInternal.

Public Member Functions

List< T > Receive (CancellationTokenSource cancellationSource=null)
 Receive a sublist of messages sent from the IScatterSender. 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...
 
- 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 a sublist of messages sent from the IScatterSender.

Template Parameters
TThe message type

Member Function Documentation

◆ Receive()

List<T> Org.Apache.REEF.Network.Group.Operators.Impl.ScatterReceiver< T >.Receive ( CancellationTokenSource  cancellationSource = null)
inline

Receive a sublist of messages sent from the IScatterSender.

Returns
The sublist of messages

Implements Org.Apache.REEF.Network.Group.Operators.IScatterReceiver< T >.

Property Documentation

◆ GroupName

Returns the name of the operator's CommunicationGroup.

◆ OperatorName

Returns the name of the reduce operator

◆ ReduceFunction

Returns the class used to reduce incoming messages sent by ReduceSenders.

◆ Version

Returns the operator version.


The documentation for this class was generated from the following file: