CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
Loading...
Searching...
No Matches
Public Member Functions | List of all members
cpark::PartitionBy< Partitioner > Class Template Reference

#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
 

Detailed Description

template<typename Partitioner>
class cpark::PartitionBy< Partitioner >

A helper class to create partition by rdd with user specified partitioner.


The documentation for this class was generated from the following file: