ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter > Class Template Reference

Detailed Description

template<typename TableItem, bool VolatileKey, typename BlockWriter>
class thrill::core::ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >

Emitter implementation to plug into a reduce hash table for collecting/flushing items while reducing. Items flushed in the pre-phase are transmitted via a network Channel.

Definition at line 46 of file reduce_pre_phase.hpp.

#include <reduce_pre_phase.hpp>

Public Member Functions
	ReducePrePhaseEmitter (std::vector< BlockWriter > &writer)
void	CloseAll ()
void	Emit (const size_t &partition_id, const TableItem &p)
void	Flush (size_t partition_id)

Public Attributes
std::vector< size_t >	stats_
	Emitter stats. More...
std::vector< BlockWriter > &	writer_
	Set of emitters, one per partition. More...

Static Private Attributes
static constexpr bool	debug = false

Constructor & Destructor Documentation

ReducePrePhaseEmitter()

ReducePrePhaseEmitter ( std::vector< BlockWriter > &  writer )

inlineexplicit

Definition at line 51 of file reduce_pre_phase.hpp.

Member Function Documentation

CloseAll()

void CloseAll ( )

inline

Definition at line 68 of file reduce_pre_phase.hpp.

References sLOG, ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::stats_, and ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::writer_.

Emit()

void Emit ( const size_t &  partition_id, const TableItem &  p  )

inline

output an element into a partition, template specialized for robust and non-robust keys

Definition at line 57 of file reduce_pre_phase.hpp.

References ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::stats_, and ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::writer_.

Flush()

void Flush ( size_t  partition_id )

inline

Definition at line 63 of file reduce_pre_phase.hpp.

References ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::writer_.

Member Data Documentation

debug

constexpr bool debug = false

staticprivate

Definition at line 48 of file reduce_pre_phase.hpp.

stats_

std::vector<size_t> stats_

Emitter stats.

Definition at line 82 of file reduce_pre_phase.hpp.

Referenced by ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::CloseAll(), and ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::Emit().

writer_

std::vector<BlockWriter>& writer_

Set of emitters, one per partition.

Definition at line 79 of file reduce_pre_phase.hpp.

Referenced by ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::CloseAll(), ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::Emit(), and ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::Flush().

---

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

• thrill/core/reduce_pre_phase.hpp