Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
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... | |
The class used to aggregate pipelined messages sent by ReduceSenders.
T | The message type. |
|
inline |
|
inline |
Reduce the IEnumerable of pipeline messages into one pipeline message.
elements | The pipeline messages to reduce |