Searched refs:fAggregator (Results 1 – 12 of 12) sorted by relevance
466 fAggregator.reset(new RowAggregation); in initBPP()467 bs >> *(fAggregator.get()); in initBPP()1079 if (fAggregator.get() != NULL) in initProcessor()1645 if (doJoin && (fe2 || fAggregator)) in execute()1686 if (fAggregator) in execute()1754 if (!fAggregator) in execute()1768 if (!doJoin && fAggregator) in execute()1797 if (!fAggregator && !fe2) in execute()2392 if (fAggregator.get() != NULL) in duplicate()2396 fAggregator->getGroupByCols(), fAggregator->getAggFunctions())); in duplicate()[all …]
347 rowgroup::SP_ROWAGG_PM_t fAggregator; variable
357 fAggregator(agg), in TupleAggregateStep()462 uint32_t hashlen = fAggregator->aggMapKeyLength(); in doThreadedSecondPhaseAggregate()621 if (fAggregator->nextRowGroup()) in nextBand_singleThread()623 fAggregator->finalize(); in nextBand_singleThread()712 fAggregator = fAggregatorUM; in setPmHJAggregation()5133 fAggregator->constantAggregate(constAggDataVec); in addConstangAggregate()5179 fAggregator->addRowGroup(&fRowGroupIn); in aggregateRowGroups()5551 while (fAggregator->nextRowGroup()) in doAggregate_singleThread()5553 fAggregator->finalize(); in doAggregate_singleThread()5644 …if (dynamic_cast<RowAggregationDistinct*>(fAggregator.get()) && fAggregator->aggMapKeyLength() > 0) in doThreadedAggregate()[all …]
120 rowgroup::SP_ROWAGG_UM_t fAggregator; variable
870 return fAggregator; in aggregator()874 fAggregator = std::move(aggregator); in aggregator()893 boost::shared_ptr<RowAggregation> fAggregator; variable
4220 fAggregator.reset(rhs.fAggregator->clone()); in RowAggregationDistinct()4241 fAggregator->setInputOutput(pRowGroupIn, &fRowGroupDist); in setInputOutput()4253 fAggregator = agg; in addAggregator()4263 fAggregator->addRowGroup(pRows); in addRowGroup()4269 fAggregator->addRowGroup(pRows, inRows); in addRowGroup()4279 while (dynamic_cast<RowAggregationUM*>(fAggregator.get())->nextRowGroup()) in doDistinctAggregation()4281 fRowGroupIn.setData(fAggregator->getOutputRowGroup()->getRGData()); in doDistinctAggregation()4539 fAggregator.reset(rhs.fAggregator->clone()); in RowAggregationMultiDistinct()