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 Types | |
using | difference_type = std::ptrdiff_t |
using | value_type = ValueType |
using | CacheIterator = std::ranges::iterator_t< const CacheType > |
using | OriginalIterator = DerivedSplitIterator |
Public Member Functions | |
Iterator (const CacheIterator &iterator) | |
Iterator (const OriginalIterator &iterator) | |
value_type | operator* () const |
Iterator & | operator++ () |
Iterator | operator++ (int) |
bool | operator== (const Iterator &other) const |
bool | operator!= (const Iterator &other) const |
Iterator & | operator-- () |
Iterator | operator-- (int) |
Iterator & | operator+= (const difference_type &n) |
Iterator & | operator-= (const difference_type &n) |
Iterator | operator+ (const difference_type &n) const |
Iterator | operator- (const difference_type &n) const |
value_type | operator[] (const difference_type &n) const |
difference_type | operator- (const Iterator &other) const |
bool | operator< (const Iterator &other) const |
bool | operator> (const Iterator &other) const |
bool | operator<= (const Iterator &other) const |
bool | operator>= (const Iterator &other) const |
Friends | |
Iterator | operator+ (const difference_type &n, const Iterator &iter) |
A special kind of iterator, who will possibly read the data using the iterator from DerivedSplit, or read the data from the execution context's cache, depending on how this iterator is initialized. This iterator is a random_access_iterator.
|
inlineexplicit |
If the iterator is initialized from this constructor, it will read values from cache.
|
inlineexplicit |
If the iterator is initialized from this constructor, it will read values from DerivedSplit.
|
inline |
See operator+=().
|
inline |
Moves the iterator to point to the next element, returns the incremented iterator.
|
inline |
Moves the iterator to point to the next element, returns the original iterator.
|
inline |
Forward the iterator to the next n-th element. It has a calculate-cache-on-miss behavior. See CacheSplit
's docs for more details.
|
inline |
Get the difference between iterators. calculate-cache-on-miss behavior. Throws if two iterators are not of the same actual type (cached or original).
|
inline |
Moves the iterator to point to the previous element, returns the decremented iterator. It has a calculate-cache-on-miss behavior. See CacheSplit
's docs for more details.
|
inline |
Moves the iterator to point to the previous element, returns the old iterator. It has a calculate-cache-on-miss behavior. See CacheSplit
's docs for more details.
|
inline |
Move the iterator to the previous n-th element. It has a calculate-cache-on-miss behavior. See CacheSplit
's docs for more details.
|
inline |
Two Iterator-s are equal if and only if they read the elements from the same source (both are reading from cache, or both are reading from original iterator), and they also point to the same value.
|
inline |
Get the next n-th element. calculate-cache-on-miss.