libfaster API Documentation  Development Version
Super fast distributted computing
Reduce Operators

Description

Run a n to 1 reduce.

Parameters
K- Key type of the created dataset
T- Value type of the source dataset
funcP- A function pointer of a user function T F(T,T) that will be used to summarize values
Returns
summarized value of type T

Functions

faster::fdd< T >::reduce (reduceFunctionP< T > funcP)
 summarizes a fdd<T> into a single value of type T
 

Typedefs

template<typename T >
using faster::reduceFunctionP = T(*)(T &a, T &b)
 
template<typename T >
using faster::PreducePFunctionP = std::pair< T *, size_t >(*)(T *a, size_t sizeA, T *b, size_t sizeB)
 
template<typename K , typename T >
using faster::IreduceIFunctionP = std::pair< K, T >(*)(const K &keyA, T &a, const K &keyB, T &b)
 
template<typename K , typename T >
using faster::IPreduceIPFunctionP = std::tuple< K, T *, size_t >(*)(K keyA, T *a, size_t sizeA, K keyB, T *b, size_t sizeB)