CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <transformed_rdd.h>
Public Member Functions | |
Transform (Func func) | |
template<concepts::Rdd R, typename T = utils::RddElementType<R>, typename U = std::invoke_result_t<Func, T>> requires std::invocable<Func, T>&& std::convertible_to<std::invoke_result_t<Func, T>, U> | |
auto | operator() (const R &r) const |
Helper class to create Transformed Rdd with pipeline operator |
.