Function _aggregateRecord

src/execution_plan/ops/op_aggregate.c:173–189

}

static void _aggregateRecord
(
	OpAggregate *op,
	Record r
) {
	// get group
	Group *g = _GetGroup(op, r);
	ASSERT(g != NULL);

	// aggregate group exps
	for(uint i = 0; i < op->aggregate_count; i++) {
		AR_ExpNode *exp = g->agg[i];
		AR_EXP_Aggregate(exp, r);
	}

	OpBase_DeleteRecord(r);
}

// returns a record populated with group data
static Record _handoff