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.