Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T > Class Template Reference

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

Send()

void Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.Send ( T  data, CancellationTokenSource  cancellationSource = null  )

inline

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

Parameters

data	The data to send
cancellationSource	The cancellationSource for cancel the operation

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

Property Documentation

GroupName

string Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.GroupName

get

Returns the name of the operator's CommunicationGroup.

OperatorName

string Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.OperatorName

get

Returns the name of the reduce operator.

PipelineDataConverter

IPipelineDataConverter<T> Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.PipelineDataConverter

get

Returns the IPipelineDataConvert used to convert messages to pipeline form and vice-versa

ReduceFunction

IReduceFunction<T> Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.ReduceFunction

get

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

Version

int Org.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T >.Version

get

Returns the operator version.

---

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

• lang/cs/Org.Apache.REEF.Network/Group/Operators/Impl/ReduceSender.cs