From d021138f3b7515feca1d27ae35f711ac7c0eb85d Mon Sep 17 00:00:00 2001 From: slzhou Date: Tue, 27 Feb 2024 09:47:55 +0800 Subject: [PATCH] remove sort by row id and comments --- source/libs/executor/src/scanoperator.c | 2 -- source/libs/executor/src/tsort.c | 6 ------ 2 files changed, 8 deletions(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 43a716a079..7f1f0700d0 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -4351,8 +4351,6 @@ SOperatorInfo* createTableMergeScanOperatorInfo(STableScanPhysiNode* pTableScanN pInfo->bSortRowId = false; } - pInfo->bSortRowId = true; - pInfo->pSortInfo = generateSortByTsInfo(pInfo->base.matchInfo.pList, pInfo->base.cond.order); pInfo->pReaderBlock = createOneDataBlock(pInfo->pResBlock, false); diff --git a/source/libs/executor/src/tsort.c b/source/libs/executor/src/tsort.c index a779a278cd..2505223273 100644 --- a/source/libs/executor/src/tsort.c +++ b/source/libs/executor/src/tsort.c @@ -1012,12 +1012,6 @@ static int32_t blockRowToBuf(SSDataBlock* pBlock, int32_t rowIdx, char* buf) { return (int32_t)(pStart - (char*)buf); } -// pageId * pageSize == pageStartOffset in file. write in pages -// when pass the page boundaries, the page is move to the front(old). -// find hash from pageid to page entry. if the page can not be found, -// 1) unused inactive pages, 2) then new pages if not exceeding mem limit, 3) then active pages -// new pages is added or moved to the back. - static int32_t getPageFromExtMemFile(SSortHandle* pHandle, int32_t pageId, char** ppPage) { SSortMemFile* pMemFile = pHandle->pExtRowsMemFile; SSortMemPageEntry** ppPageEntry = tSimpleHashGet(pMemFile->mActivePages, &pageId, sizeof(pageId));