Group Communication Operator used to send messages to be reduced by the ReduceReceiver in pipelined fashion. More...

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

Public Member Functions
void	Send (T data)
	Sends the data to the operator's ReduceReceiver to be aggregated. 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]`
	Get reduced data from children, reduce with the data given, then sends reduced data to parent 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.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 send messages to be reduced by the ReduceReceiver in pipelined fashion.

Template Parameters

T	The message type

Member Function Documentation

void Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.Send ( T data )

inline

Sends the data to the operator's ReduceReceiver to be aggregated.

Parameters

data	The data to send

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

Get reduced data from children, reduce with the data given, then sends reduced data to parent

get

Returns the operator version.

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