18 #ifndef COMBINER_PROCESSOR_H
19 #define COMBINER_PROCESSOR_H
36 template <
class KeyType,
class ValueType>
48 void loadOutputPage(
void* pageToWriteTo,
size_t numBytesInPage)
override;
PDBMapIterator< KeyType, ValueType > * end
void clearInputPage() override
Handle< Vector< Handle< Map< KeyType, ValueType > > > > inputData
void loadOutputPage(void *pageToWriteTo, size_t numBytesInPage) override
unsigned int HashPartitionID
PDBMapIterator< KeyType, ValueType > * begin
void initialize() override
void clearOutputPage() override
Handle< Map< KeyType, ValueType > > curMap
UseTemporaryAllocationBlockPtr blockPtr
bool fillNextOutputPage() override
CombinerProcessor(std::vector< HashPartitionID > &partitions)
std::vector< HashPartitionID > nodePartitionIds
std::shared_ptr< UseTemporaryAllocationBlock > UseTemporaryAllocationBlockPtr
void loadInputPage(void *pageToProcess) override
void addNodePartition(HashPartitionID partitionId)
Handle< Vector< Handle< AggregationMap< KeyType, ValueType > > > > outputData
Handle< AggregationMap< KeyType, ValueType > > curOutputMap
HashPartitionID curPartId