MCPcopy Create free account
hub / github.com/bytedance/bolt / computeAggregate

Method computeAggregate

bolt/exec/AggregateWindow.cpp:295–308  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

293 }
294
295 void computeAggregate(
296 SelectivityVector rows,
297 vector_size_t startFrame,
298 vector_size_t endFrame) {
299 rows.clearAll();
300 rows.setValidRange(startFrame, endFrame, true);
301 rows.updateBounds();
302
303 BaseVector::prepareForReuse(aggregateResultVector_, 1);
304
305 aggregate_->addSingleGroupRawInput(
306 rawSingleGroupRow_, rows, argVectors_, false);
307 aggregate_->extractValues(&rawSingleGroupRow_, 1, &aggregateResultVector_);
308 }
309
310 void incrementalAggregation(
311 const SelectivityVector& validRows,

Callers

nothing calls this directly

Calls 5

setValidRangeMethod · 0.80
updateBoundsMethod · 0.80
clearAllMethod · 0.45
extractValuesMethod · 0.45

Tested by

no test coverage detected