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

The class used to aggregate pipelined messages sent by ReduceSenders. More...

Inherits IReduceFunction< PipelineMessage< T >>.

Public Member Functions
	PipelinedReduceFunction (IReduceFunction< T > baseReduceFunc)
PipelineMessage< T >	Reduce (IEnumerable< PipelineMessage< T >> elements)
	Reduce the IEnumerable of pipeline messages into one pipeline message. More...

Detailed Description

The class used to aggregate pipelined messages sent by ReduceSenders.

Template Parameters

T	The message type.

Constructor & Destructor Documentation

PipelinedReduceFunction()

Org.Apache.REEF.Network.Group.Operators.Impl.PipelinedReduceFunction< T >.PipelinedReduceFunction ( IReduceFunction< T >  baseReduceFunc )

inline

Member Function Documentation

Reduce()

PipelineMessage<T> Org.Apache.REEF.Network.Group.Operators.Impl.PipelinedReduceFunction< T >.Reduce ( IEnumerable< PipelineMessage< T >>  elements )

inline

Reduce the IEnumerable of pipeline messages into one pipeline message.

Parameters

elements

The pipeline messages to reduce

Returns

The reduced pipeline message

---

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

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