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 (CancellationTokenSource cancellationSource=null)
	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...