feat(query): add mavg function

1e503061 · Ganlin Zhao · 8d21c662 · 1e503061
隐藏空白更改
内联并排

Showing with 12 addition and 8 deletion

source/libs/function/src/builtinsimpl.c source/libs/function/src/builtinsimpl.c +12 -8

未找到文件。
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -3013,18 +3013,22 @@ int32_t mavgFunction(SqlFunctionCtx* pCtx) {
      } else {
        pInfo->sum = pInfo->sum + v - pInfo->points[pInfo->pos];
      }
-    }
-    pInfo->points[pInfo->pos] = v;
+      pInfo->points[pInfo->pos] = v;
-    double result = pInfo->sum / pInfo->numOfPoints;
+      double result = pInfo->sum / pInfo->numOfPoints;
-    colDataAppend(pOutput, pos, (char *)&result, false);
+      colDataAppend(pOutput, pos, (char *)&result, false);
-    //TODO: remove this after pTsOutput is handled
+      //TODO: remove this after pTsOutput is handled
-    if (pTsOutput != NULL) {
+      if (pTsOutput != NULL) {
-      colDataAppendInt64(pTsOutput, pos, &tsList[i]);
+        colDataAppendInt64(pTsOutput, pos, &tsList[i]);
+      }
+      numOfElems++;
    }
-    numOfElems++;
+    pInfo->pos++;
+    if (pInfo->pos == pInfo->numOfPoints) {
+      pInfo->pos = 0;
+    }
  }
  return numOfElems;