CPARK 1.0
A light-weighted, distributed computing framework for C++ that offers a fast and general-purpose large data processing solution.
Loading...
Searching...
No Matches
Classes | Public Types | Public Member Functions | Public Attributes | List of all members
cpark::MergeRdd< R > Class Template Reference

#include <merge_rdd.h>

Inheritance diagram for cpark::MergeRdd< R >:
cpark::BaseRdd< MergeRdd< R > >

Classes

class  Iterator
 

Public Types

using Base = BaseRdd< MergeRdd< R > >
 

Public Member Functions

constexpr MergeRdd (const R &prev)
 
constexpr MergeRdd (const MergeRdd &)=default
 
MergeRddoperator= (const MergeRdd &)=default
 
- Public Member Functions inherited from cpark::BaseRdd< MergeRdd< R > >
 BaseRdd (const BaseRdd< R > &prev, bool copy_id)
 
 BaseRdd (const BaseRdd< R > &prev)
 
 BaseRdd (ExecutionContext *context)
 
BaseRddoperator= (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< MergeRdd< R > >
ExecutionContextcontext_
 
ExecutionContext::RddId rdd_id_
 
size_t splits_num_
 

Detailed Description

template<concepts::Rdd R>
class cpark::MergeRdd< R >

An Rdd holding the data merged from an old rdd by some function. This Rdd will result in only one large split contains all the element in previous Rdd's splits.

Template Parameters
RType of the old Rdd.

Constructor & Destructor Documentation

◆ MergeRdd()

template<concepts::Rdd R>
constexpr cpark::MergeRdd< R >::MergeRdd ( const R &  prev)
inlineconstexpr

Main constructor of MergeRdd.

Parameters
prevReference to previous Rdd of type R

The documentation for this class was generated from the following file: