![]() |
CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
|
#include <zipped_rdd.h>
Public Types | |
| using | Base = BaseRdd< ZippedRdd< R1, R2 > > |
| using | V1 = utils::RddElementType< R1 > |
| using | V2 = utils::RddElementType< R2 > |
Public Member Functions | |
| constexpr | ZippedRdd (const R1 &prev1, const R2 &prev2) |
| constexpr | ZippedRdd (const ZippedRdd &)=default |
| ZippedRdd & | operator= (const ZippedRdd &)=default |
Public Member Functions inherited from cpark::BaseRdd< ZippedRdd< R1, R2 > > | |
| BaseRdd (const BaseRdd< R > &prev, bool copy_id) | |
| BaseRdd (const BaseRdd< R > &prev) | |
| BaseRdd (ExecutionContext *context) | |
| BaseRdd & | operator= (const BaseRdd< R > &prev) |
| auto | begin () const |
| auto | end () const |
| ExecutionContext::RddId | id () const noexcept |
Public Attributes | |
| friend | Base |
Additional Inherited Members | |
Protected Attributes inherited from cpark::BaseRdd< ZippedRdd< R1, R2 > > | |
| ExecutionContext * | context_ |
| ExecutionContext::RddId | rdd_id_ |
| size_t | splits_num_ |
An Rdd holding the zipped data from two old rdds
| R1 | Type of the first old Rdd. |
| R2 | Type of the second old Rdd. |