18 #ifndef AGGREGATION_PROCESSOR_H
19 #define AGGREGATION_PROCESSOR_H
32 template <
class KeyType,
class ValueType>
42 void loadOutputPage(
void* pageToWriteTo,
size_t numBytesInPage)
override;
void initialize() override
void loadInputObject(Handle< Object > &objectToProcess) override
unsigned int HashPartitionID
PDBMapIterator< KeyType, ValueType > * begin
bool needsProcessInput() override
PDBMapIterator< KeyType, ValueType > * end
void loadInputPage(void *pageToProcess) override
std::shared_ptr< UseTemporaryAllocationBlock > UseTemporaryAllocationBlockPtr
bool fillNextOutputPage() override
Handle< Map< KeyType, ValueType > > outputData
UseTemporaryAllocationBlockPtr blockPtr
void loadOutputPage(void *pageToWriteTo, size_t numBytesInPage) override
Handle< Vector< Handle< AggregationMap< KeyType, ValueType > > > > inputData
Handle< AggregationMap< KeyType, ValueType > > curMap
void clearInputPage() override
void clearOutputPage() override