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::GeneratorRdd< Num, Func, T > Class Template Reference

#include <generator_rdd.h>

Inheritance diagram for cpark::GeneratorRdd< Num, Func, T >:
cpark::BaseRdd< DerivedRdd >

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
 
GeneratorRddoperator= (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>
BaseRddoperator= (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 >
ExecutionContextcontext_ {}
 
ExecutionContext::RddId rdd_id_ {}
 
size_t splits_num_ {}
 

Detailed Description

template<typename Num, typename Func, typename T = std::invoke_result_t<Func, Num>>
requires std::is_arithmetic_v<Num>&& std::invocable<Func, Num>&& std::convertible_to<std::invoke_result_t<Func, Num>, T>
class cpark::GeneratorRdd< Num, Func, T >

An Rdd that generates a sequence of data from a number range.

Template Parameters
NumThe type of the number composing the range. It must be arithmetic types.
FuncThe function that maps the number into some data. Must be invokable from Num.
TThe data type of the Rdd. Must be convertible from the result of Func.
Examples
calculate_pi.cpp, filter_even.cpp, simple.cpp, and speed_check.cpp.

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