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

adj stream op result

This commit is contained in:
54liuyao 2024-07-19 16:23:52 +08:00
parent 883741c8d5
commit a618667a5e
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1553,11 +1553,13 @@ static void prepareRangeScan(SStreamScanInfo* pInfo, SSDataBlock* pBlock, int32_
if (pBlock->info.rows == 0) { if (pBlock->info.rows == 0) {
if (pRes) { if (pRes) {
(*pRes) = false; (*pRes) = false;
goto _end;
} }
} }
if ((*pRowIndex) == pBlock->info.rows) { if ((*pRowIndex) == pBlock->info.rows) {
if (pRes) { if (pRes) {
(*pRes) = false; (*pRes) = false;
goto _end;
} }
} }
@ -1611,6 +1613,9 @@ static void prepareRangeScan(SStreamScanInfo* pInfo, SSDataBlock* pBlock, int32_
if (pRes) { if (pRes) {
(*pRes) = true; (*pRes) = true;
} }
_end:
qTrace("%s success", __func__);
} }
static STimeWindow getSlidingWindow(TSKEY* startTsCol, TSKEY* endTsCol, uint64_t* gpIdCol, SInterval* pInterval, static STimeWindow getSlidingWindow(TSKEY* startTsCol, TSKEY* endTsCol, uint64_t* gpIdCol, SInterval* pInterval,