CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <partition_by_rdd.h>
Public Member Functions | |
PartitionBy (Partitioner partitioner) | |
template<concepts::Rdd R, typename K = utils::RddKeyType<R>> requires std::invocable<Partitioner, K> && std::convertible_to<std::invoke_result_t<Partitioner, K>, size_t> | |
auto | operator() (const R &r) const |
A helper class to create partition by rdd with user specified partitioner.