Function MergeCreate_Commit

src/execution_plan/ops/op_merge_create.c:302–311

}

void MergeCreate_Commit(OpBase *opBase) {
	OpMergeCreate *op = (OpMergeCreate *)opBase;
	op->handoff_mode = true;
	/* Done reading, we're not going to call consume any longer
	 * there might be operations e.g. index scan that need to free
	 * index R/W lock, as such free all execution plan operation up the chain. */
	if(opBase->childCount > 0) OpBase_PropagateReset(opBase->children[0]);
	// Create entities.
	CommitNewEntities(opBase, &op->pending);
}

static OpBase *MergeCreateClone(const ExecutionPlan *plan, const OpBase *opBase) {
	ASSERT(opBase->type == OPType_MERGE_CREATE);