Function OptionalConsume

src/execution_plan/ops/op_optional.c:25–40

}

static Record OptionalConsume(OpBase *opBase) {
	Optional *op = (Optional *)opBase;
	// try to produce a Record from the child op.
	Record r = OpBase_Consume(opBase->children[0]);

	// create an empty Record if the child returned NULL
	// and this op has not yet returned data.
	if(!r && !op->emitted_record) {
		r = OpBase_CreateRecord(opBase);
	}

	// don't produce multiple empty Records.
	op->emitted_record = true;

	return r;
}

static OpResult OptionalReset(OpBase *opBase) {
	Optional *op = (Optional *)opBase;