Searched refs:ThreadedAggregator (Results 1 – 4 of 4) sorted by relevance
151 class ThreadedAggregator154 ThreadedAggregator(TupleAggregateStep* step, uint32_t threadID) : in ThreadedAggregator() function
5623 runners.push_back(jobstepThreadPool.invoke(ThreadedAggregator(this, i))); in doThreadedAggregate()