Function AllNodeScanConsume

src/execution_plan/ops/op_all_node_scan.c:79–90

}

static Record AllNodeScanConsume(OpBase *opBase) {
	AllNodeScan *op = (AllNodeScan *)opBase;

	Node n = GE_NEW_NODE();
	n.attributes = DataBlockIterator_Next(op->iter, &n.id);
	if(n.attributes == NULL) return NULL;

	Record r = OpBase_CreateRecord((OpBase *)op);
	Record_AddNode(r, op->nodeRecIdx, n);

	return r;
}

static OpResult AllNodeScanReset(OpBase *op) {
	AllNodeScan *allNodeScan = (AllNodeScan *)op;