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)
inlineexplicit

Definition at line 51 of file reduce_pre_phase.hpp.

Member Function Documentation

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

void Flush ( size_t  partition_id)
inline

Member Data Documentation

constexpr bool debug = false
staticprivate

Definition at line 48 of file reduce_pre_phase.hpp.


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