Function SortReset

src/execution_plan/ops/op_sort.c:178–202

restart iterator

// restart iterator
static OpResult SortReset(OpBase *ctx) {
	OpSort *op = (OpSort *)ctx;
	uint recordCount;

	if(op->heap) {
		recordCount = Heap_count(op->heap);
		for(uint i = 0; i < recordCount; i++) {
			Record r = (Record)Heap_poll(op->heap);
			OpBase_DeleteRecord(r);
		}
	}

	if(op->buffer) {
		recordCount = array_len(op->buffer);
		for(uint i = op->record_idx; i < recordCount; i++) {
			Record r = op->buffer[i];
			OpBase_DeleteRecord(r);
		}
		array_clear(op->buffer);
	}

	op->record_idx = 0;

	return OP_OK;
}

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