fix error

e38e23a3 · Ganlin Zhao · 1dd89be9 · e38e23a3
隐藏空白更改
内联并排

Showing with 18 addition and 0 deletion

source/libs/function/src/builtinsimpl.c source/libs/function/src/builtinsimpl.c +18 -0

未找到文件。
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -2598,6 +2598,15 @@ int32_t lastFunction(SqlFunctionCtx* pCtx) {
        }
        memcpy(pInfo->buf, data, bytes);
        *(TSKEY*)(pInfo->buf + bytes) = cts;
+        //handle selectivity
+        if (pCtx->subsidiaries.num > 0) {
+          STuplePos* pTuplePos = (STuplePos*)(pInfo->buf + bytes + sizeof(TSKEY));
+          if (!pInfo->hasResult) {
+            saveTupleData(pCtx, i, pCtx->pSrcBlock, pTuplePos);
+          } else {
+            copyTupleData(pCtx, i, pCtx->pSrcBlock, pTuplePos);
+          }
+        }
        pInfo->hasResult = true;
        //DO_UPDATE_TAG_COLUMNS(pCtx, ts);
        pResInfo->numOfRes = 1;
@@ -2621,6 +2630,15 @@ int32_t lastFunction(SqlFunctionCtx* pCtx) {
        }
        memcpy(pInfo->buf, data, bytes);
        *(TSKEY*)(pInfo->buf + bytes) = cts;
+        //handle selectivity
+        if (pCtx->subsidiaries.num > 0) {
+          STuplePos* pTuplePos = (STuplePos*)(pInfo->buf + bytes + sizeof(TSKEY));
+          if (!pInfo->hasResult) {
+            saveTupleData(pCtx, i, pCtx->pSrcBlock, pTuplePos);
+          } else {
+            copyTupleData(pCtx, i, pCtx->pSrcBlock, pTuplePos);
+          }
+        }
        pInfo->hasResult = true;
        pResInfo->numOfRes = 1;
        //DO_UPDATE_TAG_COLUMNS(pCtx, ts);