Function NewOptionalOp

src/execution_plan/ops/op_optional.c:14–23

static OpBase *OptionalClone(const ExecutionPlan *plan, const OpBase *opBase);

OpBase *NewOptionalOp(const ExecutionPlan *plan) {
	Optional *op = rm_malloc(sizeof(Optional));
	op->emitted_record = false;

	// Set our Op operations
	OpBase_Init((OpBase *)op, OPType_OPTIONAL, "Optional", NULL, OptionalConsume,
				OptionalReset, NULL, OptionalClone, NULL, false, plan);

	return (OpBase *)op;
}

static Record OptionalConsume(OpBase *opBase) {
	Optional *op = (Optional *)opBase;