A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | Private Attributes | List of all members
pdb::CombinerProcessor< KeyType, ValueType > Class Template Reference

#include <CombinerProcessor.h>

+ Inheritance diagram for pdb::CombinerProcessor< KeyType, ValueType >:
+ Collaboration diagram for pdb::CombinerProcessor< KeyType, ValueType >:

Public Member Functions

 ~CombinerProcessor ()
 
 CombinerProcessor (std::vector< HashPartitionID > &partitions)
 
void initialize () override
 
void loadInputPage (void *pageToProcess) override
 
void loadOutputPage (void *pageToWriteTo, size_t numBytesInPage) override
 
bool fillNextOutputPage () override
 
void finalize () override
 
void clearOutputPage () override
 
void clearInputPage () override
 
void addNodePartition (HashPartitionID partitionId)
 
- Public Member Functions inherited from pdb::SimpleSingleTableQueryProcessor
virtual void loadInputObject (Handle< Object > &objectToProcess)
 
virtual bool needsProcessInput ()
 

Private Attributes

UseTemporaryAllocationBlockPtr blockPtr
 
Handle< Vector< Handle< Map
< KeyType, ValueType > > > > 		inputData
 
Handle< Vector< Handle
< AggregationMap< KeyType,
ValueType > > > > 		outputData
 
bool finalized
 
int numNodePartitions
 
HashPartitionID curPartId
 
int curPartPos
 
Handle< Map< KeyType, ValueType > > curMap
 
Handle< AggregationMap
< KeyType, ValueType > > 		curOutputMap
 
PDBMapIterator< KeyType,
ValueType > * 		begin
 
PDBMapIterator< KeyType,
ValueType > * 		end
 
std::vector< HashPartitionID > nodePartitionIds
 
int count
 

Detailed Description

template<class KeyType, class ValueType>
class pdb::CombinerProcessor< KeyType, ValueType >

Definition at line 37 of file CombinerProcessor.h.

Constructor & Destructor Documentation

template<class KeyType , class ValueType >
pdb::CombinerProcessor< KeyType, ValueType >::~CombinerProcessor ( )
inline

Definition at line 40 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
pdb::CombinerProcessor< KeyType, ValueType >::CombinerProcessor ( std::vector< HashPartitionID > &  partitions)

Definition at line 28 of file CombinerProcessor.cc.

Member Function Documentation

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::addNodePartition ( HashPartitionID  partitionId)
template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::clearInputPage ( )
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 216 of file CombinerProcessor.cc.

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::clearOutputPage ( )
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 209 of file CombinerProcessor.cc.

template<class KeyType , class ValueType >
bool pdb::CombinerProcessor< KeyType, ValueType >::fillNextOutputPage ( )
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 97 of file CombinerProcessor.cc.

+ Here is the call graph for this function:

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::finalize ( )
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 204 of file CombinerProcessor.cc.

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::initialize ( )
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 46 of file CombinerProcessor.cc.

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::loadInputPage ( void *  pageToProcess)
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 52 of file CombinerProcessor.cc.

+ Here is the call graph for this function:

template<class KeyType , class ValueType >
void pdb::CombinerProcessor< KeyType, ValueType >::loadOutputPage ( void *  pageToWriteTo,
size_t  numBytesInPage 
)
overridevirtual

Implements pdb::SimpleSingleTableQueryProcessor.

Definition at line 75 of file CombinerProcessor.cc.

Member Data Documentation

template<class KeyType , class ValueType >
PDBMapIterator<KeyType, ValueType>* pdb::CombinerProcessor< KeyType, ValueType >::begin
private

Definition at line 67 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
UseTemporaryAllocationBlockPtr pdb::CombinerProcessor< KeyType, ValueType >::blockPtr
private

Definition at line 56 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
int pdb::CombinerProcessor< KeyType, ValueType >::count
private

Definition at line 72 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
Handle<Map<KeyType, ValueType> > pdb::CombinerProcessor< KeyType, ValueType >::curMap
private

Definition at line 63 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
Handle<AggregationMap<KeyType, ValueType> > pdb::CombinerProcessor< KeyType, ValueType >::curOutputMap
private

Definition at line 64 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
HashPartitionID pdb::CombinerProcessor< KeyType, ValueType >::curPartId
private

Definition at line 61 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
int pdb::CombinerProcessor< KeyType, ValueType >::curPartPos
private

Definition at line 62 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
PDBMapIterator<KeyType, ValueType>* pdb::CombinerProcessor< KeyType, ValueType >::end
private

Definition at line 68 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
bool pdb::CombinerProcessor< KeyType, ValueType >::finalized
private

Definition at line 59 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
Handle<Vector<Handle<Map<KeyType, ValueType> > > > pdb::CombinerProcessor< KeyType, ValueType >::inputData
private

Definition at line 57 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
std::vector<HashPartitionID> pdb::CombinerProcessor< KeyType, ValueType >::nodePartitionIds
private

Definition at line 71 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
int pdb::CombinerProcessor< KeyType, ValueType >::numNodePartitions
private

Definition at line 60 of file CombinerProcessor.h.

template<class KeyType , class ValueType >
Handle<Vector<Handle<AggregationMap<KeyType, ValueType> > > > pdb::CombinerProcessor< KeyType, ValueType >::outputData
private

Definition at line 58 of file CombinerProcessor.h.

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