xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

remove sort by row id and comments

This commit is contained in:
slzhou 2024-02-27 09:47:55 +08:00
parent dc6d96da70
commit d021138f3b
2 changed files with 0 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/executor/src/scanoperator.c
View File

@ -4351,8 +4351,6 @@ SOperatorInfo* createTableMergeScanOperatorInfo(STableScanPhysiNode* pTableScanN
pInfo->bSortRowId = false; pInfo->bSortRowId = false;
} }
pInfo->bSortRowId = true;
pInfo->pSortInfo = generateSortByTsInfo(pInfo->base.matchInfo.pList, pInfo->base.cond.order); pInfo->pSortInfo = generateSortByTsInfo(pInfo->base.matchInfo.pList, pInfo->base.cond.order);
pInfo->pReaderBlock = createOneDataBlock(pInfo->pResBlock, false); pInfo->pReaderBlock = createOneDataBlock(pInfo->pResBlock, false);

6
source/libs/executor/src/tsort.c
View File

@ -1012,12 +1012,6 @@ static int32_t blockRowToBuf(SSDataBlock* pBlock, int32_t rowIdx, char* buf) {
return (int32_t)(pStart - (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) { static int32_t getPageFromExtMemFile(SSortHandle* pHandle, int32_t pageId, char** ppPage) {
SSortMemFile* pMemFile = pHandle->pExtRowsMemFile; SSortMemFile* pMemFile = pHandle->pExtRowsMemFile;
SSortMemPageEntry** ppPageEntry = tSimpleHashGet(pMemFile->mActivePages, &pageId, sizeof(pageId)); SSortMemPageEntry** ppPageEntry = tSimpleHashGet(pMemFile->mActivePages, &pageId, sizeof(pageId));