Function CreateConsume

src/execution_plan/ops/op_create.c:139–197

}

static Record CreateConsume
(
	OpBase *opBase
) {
	OpCreate *op = (OpCreate *)opBase;
	Record r;

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

	// consume mode
	op->records = array_new(Record, 32);

	// initialize the records array with NULL, which will terminate execution
	// upon depletion
	array_append(op->records, NULL);

	OpBase       *child = NULL;
	GraphContext *gc    = QueryCtx_GetGraphCtx();

	if(op->op.childCount == 0) {
		// no child operation to call
		r = OpBase_CreateRecord(opBase);
		// create entities
		_CreateNodes(op, r, gc);
		_CreateEdges(op, r, gc);

		// save record for later use
		array_append(op->records, r);
	} else {
		// pull data until child is depleted
		child = op->op.children[0];
		while((r = OpBase_Consume(child))) {
			// persist scalars from previous ops before storing the record
			// as those ops will be freed before the records are handed off
			Record_PersistScalars(r);

			// create entities
			_CreateNodes(op, r, gc);
			_CreateEdges(op, r, gc);

			// save record for later use
			array_append(op->records, r);
		}
	}

	// 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(child) {
		OpBase_PropagateReset(child);
	}

	// create entities
	CommitNewEntities(opBase, &op->pending);

	// return record
	return _handoff(op);