CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <collect.h>
Public Member Functions | |
Collect ()=default | |
template<concepts::Rdd R, typename T = utils::RddElementType<R>> | |
std::vector< T > | operator() (const R &rdd) const |
A class that collects all the partitions in an Rdd into a single vector.
|
explicitdefault |
Initialize the Collect class
Collect the elements of the Rdd rdd
into a vector.