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

refactor: do some internal refactor.

This commit is contained in:
Haojun Liao 2024-03-22 17:26:56 +08:00
parent 018e6f2a71
commit cbf22ed72a
1 changed files with 26 additions and 57 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
source/dnode/vnode/src/tsdb/tsdbRead2.c
View File

@ -1697,68 +1697,37 @@ static int32_t doMergeBufAndFileRows(STsdbReader* pReader, STableBlockScanInfo*
// be changed, resulting in the corresponding changing of the value of sttRowKey // be changed, resulting in the corresponding changing of the value of sttRowKey
tRowKeyAssign(&pBlockScanInfo->lastProcKey, &minKey); tRowKeyAssign(&pBlockScanInfo->lastProcKey, &minKey);
// ASC: file block ---> last block -----> imem -----> mem // ASC: file block ---> stt block -----> mem
// DESC: mem -----> imem -----> last block -----> file block if (pkCompEx(compFn, &minKey, pfKey) == 0) {
// if (pReader->info.order == TSDB_ORDER_ASC) { int32_t code = tsdbRowMergerAdd(pMerger, &fRow, NULL);
if (pkCompEx(compFn, &minKey, pfKey) == 0) { if (code != TSDB_CODE_SUCCESS) {
int32_t code = tsdbRowMergerAdd(pMerger, &fRow, NULL); return code;
if (code != TSDB_CODE_SUCCESS) {
return code;
}
doMergeRowsInFileBlocks(pBlockData, pBlockScanInfo, pfKey, pReader);
} }
if (pkCompEx(compFn, &minKey, pSttKey) == 0) { doMergeRowsInFileBlocks(pBlockData, pBlockScanInfo, pfKey, pReader);
TSDBROW* fRow1 = tMergeTreeGetRow(&pSttBlockReader->mergeTree); }
int32_t code = tsdbRowMergerAdd(pMerger, fRow1, NULL);
if (code != TSDB_CODE_SUCCESS) { if (pkCompEx(compFn, &minKey, pSttKey) == 0) {
return code; TSDBROW* fRow1 = tMergeTreeGetRow(&pSttBlockReader->mergeTree);
} int32_t code = tsdbRowMergerAdd(pMerger, fRow1, NULL);
doMergeRowsInSttBlock(pSttBlockReader, pBlockScanInfo, pSttKey, pMerger, pkSrcSlot, &pReader->info.verRange, pReader->idStr); if (code != TSDB_CODE_SUCCESS) {
return code;
}
doMergeRowsInSttBlock(pSttBlockReader, pBlockScanInfo, pSttKey, pMerger, pkSrcSlot, &pReader->info.verRange,
pReader->idStr);
}
if (pkCompEx(compFn, &minKey, &k) == 0) {
int32_t code = tsdbRowMergerAdd(pMerger, pRow, pSchema);
if (code != TSDB_CODE_SUCCESS) {
return code;
} }
if (pkCompEx(compFn, &minKey, &k) == 0) { code = doMergeRowsInBuf(pIter, pBlockScanInfo->uid, &k, pBlockScanInfo->delSkyline, pReader);
int32_t code = tsdbRowMergerAdd(pMerger, pRow, pSchema); if (code != TSDB_CODE_SUCCESS) {
if (code != TSDB_CODE_SUCCESS) { return code;
return code;
}
code = doMergeRowsInBuf(pIter, pBlockScanInfo->uid, &k, pBlockScanInfo->delSkyline, pReader);
if (code != TSDB_CODE_SUCCESS) {
return code;
}
} }
/*} else { }
if (pkCompEx(compFn, &minKey, &k) == 0) {
int32_t code = tsdbRowMergerAdd(pMerger, pRow, pSchema);
if (code != TSDB_CODE_SUCCESS) {
return code;
}
code = doMergeRowsInBuf(pIter, pBlockScanInfo->uid, &k, pBlockScanInfo->delSkyline, pReader);
if (code != TSDB_CODE_SUCCESS || pMerger->pTSchema == NULL) {
return code;
}
}
if (pkCompEx(compFn, &minKey, pSttKey) == 0) {
TSDBROW* fRow1 = tMergeTreeGetRow(&pSttBlockReader->mergeTree);
int32_t code = tsdbRowMergerAdd(pMerger, fRow1, NULL);
if (code != TSDB_CODE_SUCCESS) {
return code;
}
doMergeRowsInSttBlock(pSttBlockReader, pBlockScanInfo, pSttKey, pMerger, pkSrcSlot, &pReader->info.verRange, pReader->idStr);
}
if (pkCompEx(compFn, &minKey, pfKey) == 0) {
int32_t code = tsdbRowMergerAdd(pMerger, &fRow, NULL);
if (code != TSDB_CODE_SUCCESS) {
return code;
}
doMergeRowsInFileBlocks(pBlockData, pBlockScanInfo, pfKey, pReader);
}
}*/
int32_t code = tsdbRowMergerGetRow(pMerger, &pTSRow); int32_t code = tsdbRowMergerGetRow(pMerger, &pTSRow);
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {