Function NewCallSubqueryOp

src/execution_plan/ops/op_call_subquery.c:69–91

creates a new CallSubquery operation

// creates a new CallSubquery operation
OpBase *NewCallSubqueryOp
(
	const ExecutionPlan *plan,  // execution plan
	bool is_eager,              // is the subquery eager or not
	bool is_returning           // is the subquery returning or not
) {
	OpCallSubquery *op = rm_calloc(1, sizeof(OpCallSubquery));

	op->first        = true;
	op->is_eager     = is_eager;
	op->is_returning = is_returning;

	// set the consume function according to eagerness of the op
	fpConsume consumeFunc = is_eager ?
		CallSubqueryConsumeEager :
		CallSubqueryConsume;

	OpBase_Init((OpBase *)op, OPType_CALLSUBQUERY, "CallSubquery",
		CallSubqueryInit, consumeFunc, CallSubqueryReset, NULL,
		CallSubqueryClone, CallSubqueryFree, false, plan);

	return (OpBase *)op;
}

static OpResult CallSubqueryInit
(