CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <reduce.h>
Public Member Functions | |
Reduce (Func func) | |
template<concepts::Rdd R, typename T = utils::RddElementType<R>> requires std::invocable<Func, T, T>&& std::convertible_to<std::invoke_result_t<Func, T, T>, T>&& std::is_default_constructible_v<T> | |
T | operator() (const R &rdd) const |
A class who receives a function (callable object) and calculate the reduced result of Rdd using the function.
|
inlineexplicit |
Initialize the Reduce class with a callable object func
.
|
inline |
Compute the result of the Rdd rdd
with the function.