cpark::GroupByKeyRdd< R > Class Template Reference

#include <group_by_key_rdd.h>

Inheritance diagram for cpark::GroupByKeyRdd< R >:

Classes
class	Iterator

Public Types
using	Base = BaseRdd< GroupByKeyRdd< R > >
using	KeyType = utils::RddKeyType< R >
using	ValueType = utils::RddValueType< R >

Public Member Functions
	GroupByKeyRdd (const R &prev)
	GroupByKeyRdd (const GroupByKeyRdd &)=default
GroupByKeyRdd &	operator= (const GroupByKeyRdd &)=default
Public Member Functions inherited from cpark::BaseRdd< GroupByKeyRdd< R > >
	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< GroupByKeyRdd< R > >
ExecutionContext *	context_
ExecutionContext::RddId	rdd_id_
size_t	splits_num_

Detailed Description

template<concepts::KeyValueRdd R>
requires concepts::KeyValueRdd<R>
class cpark::GroupByKeyRdd< R >

An Rdd that performs group-by-key operation to a previous key-value typed Rdd. The values that have the same key will be grouped into a sequence, and the sequence will be the value of this key in the new Rdd.

Template Parameters

R	The previous Rdd. Must be of key-value type. Must be already partitioned. TODO: Add support for un-partition-ed Rdd-s with an extra partition.

Constructor & Destructor Documentation

GroupByKeyRdd()

template<concepts::KeyValueRdd R>

cpark::GroupByKeyRdd< R >::GroupByKeyRdd ( const R &  prev )

inlineexplicit

Creates GroupByKeyRdd from a previous Rdd.

---

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

• include/group_by_key_rdd.h