Function MergeCreateConsume

src/execution_plan/ops/op_merge_create.c:265–300

}

static Record MergeCreateConsume(OpBase *opBase) {
	OpMergeCreate *op = (OpMergeCreate *)opBase;
	Record r;

	// Return mode, all data was consumed.
	if(op->handoff_mode) return _handoff(op);

	// Consume mode.
	if(!opBase->childCount) {
		// No child operation to call.
		r = OpBase_CreateRecord(opBase);

		/* Buffer all entity creations.
		 * If this operation has no children, it should always have unique creations. */
		bool entities_created = _CreateEntities(op, r, op->gc);
		ASSERT(entities_created == true);

		// Save record for later use.
		array_append(op->records, r);
	} else {
		// Pull record from child.
		r = OpBase_Consume(opBase->children[0]);
		if(r) {
			/* Create entities. */
			if(_CreateEntities(op, r, op->gc)) {
				// Save record for later use.
				array_append(op->records, r);
			} else {
				OpBase_DeleteRecord(r);
			}
		}
	}

	// MergeCreate returns no data while in creation mode.
	return NULL;
}

void MergeCreate_Commit(OpBase *opBase) {
	OpMergeCreate *op = (OpMergeCreate *)opBase;