Function _GetGroup

src/execution_plan/ops/op_aggregate.c:138–171

retrieves group under which given record belongs to creates group if it doesn't exists

// retrieves group under which given record belongs to
// creates group if it doesn't exists
static Group *_GetGroup
(
	OpAggregate *op,
	Record r
) {
	// construct group key
	// evaluate non-aggregated fields

	SIValue keys[op->key_count];
	XXH64_hash_t hash = _ComputeGroupKey(keys, op, r);

	// lookup group by hashed key
	Group *g;
	dictEntry *existing;
	dictEntry *entry = HashTableAddRaw(op->groups, (void *)hash, &existing);
	if(entry == NULL) {
		// group exists
		ASSERT(existing != NULL);

		// free computed keys
		for(uint i = 0; i < op->key_count; i++) {
			SIValue_Free(keys[i]);
		}

		g = HashTableGetVal(existing);
	} else {
		// entry missing
		// group does not exists, create it
		g = _CreateGroup(op, keys);
		HashTableSetVal(op->groups, entry, g);
	}

	return g;
}

static void _aggregateRecord
(