![]() |
CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <generator_rdd.h>
Classes | |
| class | Iterator |
Public Types | |
| using | Base = BaseRdd< GeneratorRdd< Num, Func, T > > |
Public Member Functions | |
| constexpr | GeneratorRdd (Num begin, Num end, Func func, ExecutionContext *context) |
| constexpr | GeneratorRdd (const GeneratorRdd &)=default |
| GeneratorRdd & | operator= (const GeneratorRdd &)=default |
Public Member Functions inherited from cpark::BaseRdd< DerivedRdd > | |
| template<concepts::Rdd R> | |
| BaseRdd (const BaseRdd< R > &prev, bool copy_id) | |
| template<concepts::Rdd R> | |
| BaseRdd (const BaseRdd< R > &prev) | |
| template<concepts::Rdd R> | |
| BaseRdd & | operator= (const BaseRdd< R > &prev) |
| BaseRdd (ExecutionContext *context) | |
| auto | begin () const |
| auto | end () const |
| ExecutionContext::RddId | id () const noexcept |
Public Attributes | |
| friend | Base |
Additional Inherited Members | |
Protected Attributes inherited from cpark::BaseRdd< DerivedRdd > | |
| ExecutionContext * | context_ {} |
| ExecutionContext::RddId | rdd_id_ {} |
| size_t | splits_num_ {} |
An Rdd that generates a sequence of data from a number range.
| Num | The type of the number composing the range. It must be arithmetic types. |
| Func | The function that maps the number into some data. Must be invokable from Num. |
| T | The data type of the Rdd. Must be convertible from the result of Func. |