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

fix: fill value issue

This commit is contained in:
dapan1121 2022-12-22 20:56:23 +08:00
parent dacb2cd533
commit 9ab98f0230
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/executor/src/tfill.c
View File

@ -293,12 +293,14 @@ static int32_t fillResultImpl(SFillInfo* pFillInfo, SSDataBlock* pBlock, int32_t
int64_t ts = ((int64_t*)pTsCol->pData)[pFillInfo->index]; int64_t ts = ((int64_t*)pTsCol->pData)[pFillInfo->index];
// set the next value for interpolation // set the next value for interpolation
if (pFillInfo->currentKey < ts && ascFill) { if ((pFillInfo->currentKey < ts && ascFill) || (pFillInfo->currentKey > ts && !ascFill)) {
copyCurrentRowIntoBuf(pFillInfo, pFillInfo->index, &pFillInfo->prev);
} else if (pFillInfo->currentKey > ts && !ascFill) {
copyCurrentRowIntoBuf(pFillInfo, pFillInfo->index, &pFillInfo->next); copyCurrentRowIntoBuf(pFillInfo, pFillInfo->index, &pFillInfo->next);
} }
if (pFillInfo->currentKey < ts && ascFill && 0 == pFillInfo->index) {
copyCurrentRowIntoBuf(pFillInfo, pFillInfo->index, &pFillInfo->prev);
}
if (((pFillInfo->currentKey < ts && ascFill) || (pFillInfo->currentKey > ts && !ascFill)) && if (((pFillInfo->currentKey < ts && ascFill) || (pFillInfo->currentKey > ts && !ascFill)) &&
pFillInfo->numOfCurrent < outputRows) { pFillInfo->numOfCurrent < outputRows) {
// fill the gap between two input rows // fill the gap between two input rows