![]() |
CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <base_rdd.h>
Public Member Functions | |
| 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 |
Protected Attributes | |
| ExecutionContext * | context_ {} |
| ExecutionContext::RddId | rdd_id_ {} |
| size_t | splits_num_ {} |
A base class that holds common interfaces, operations and variables for all different Rdd-s. This class uses CRTP to achieve compile-time polymorphism to avoid the run-time cost of virtual functions.
| DerivedRdd | The type of the derived Rdd. Derived Rdd class should implement these functions: beginImpl(), endImpl(). |
|
inlineexplicit |
|
inlineexplicit |
Copy constructor for each kind of BaseRdd class.
|
inlineexplicit |
|
inline |
Returns an forward Iterator that points to the first split contained in this Rdd.
|
inline |
Returns an iterator sentinel which marks the end for the iterators pointing to the splits in this Rdd.
|
inlinenoexcept |
Returns the rdd id.
|
inline |
Assignment operator for each kind of BaseRdd class.