Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
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 ( std::vector< BlockWriter > &  writer)

Definition at line 51 of file reduce_pre_phase.hpp.

Member Function Documentation

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

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_.

void Flush ( size_t  partition_id)

Member Data Documentation

constexpr bool debug = false

Definition at line 48 of file reduce_pre_phase.hpp.

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