Function AggregateFree

src/execution_plan/ops/op_aggregate.c:398–437

}

static void AggregateFree
(
	OpBase *opBase
) {
	OpAggregate *op = (OpAggregate *)opBase;
	if(op == NULL) {
		return;
	}

	if(op->group_iter) {
		HashTableReleaseIterator(op->group_iter);
		op->group_iter = NULL;
	}

	if(op->key_exps) {
		for(uint i = 0; i < op->key_count; i++) {
			AR_EXP_Free(op->key_exps[i]);
		}
		array_free(op->key_exps);
		op->key_exps = NULL;
	}

	if(op->aggregate_exps) {
		for(uint i = 0; i < op->aggregate_count; i++) {
			AR_EXP_Free(op->aggregate_exps[i]);
		}
		array_free(op->aggregate_exps);
		op->aggregate_exps = NULL;
	}

	if(op->groups) {
		HashTableRelease(op->groups);
		op->groups = NULL;
	}

	if(op->record_offsets) {
		array_free(op->record_offsets);
		op->record_offsets = NULL;
	}
}