Function DeleteConsume

src/execution_plan/ops/op_delete.c:197–236

}

static Record DeleteConsume(OpBase *opBase) {
	OpDelete *op = (OpDelete *)opBase;
	Record r;
	ASSERT(op->op.childCount > 0);

	// 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);

	GraphContext *gc = QueryCtx_GetGraphCtx();
	// pull data until child is depleted
	OpBase *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);

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

		// collect entities to be deleted
		_CollectDeletedEntities(r, opBase);
	}

	// 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 reset all execution plan operation up the chain
	OpBase_PropagateReset(child);

	// delete entities
	_DeleteEntities(op);

	// return record
	return _handoff(op);
}

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