feat(query): add timediff function

TD-14243

feat(query): add timediff function
TD-14243
eabfc7d3 · Ganlin Zhao · Ganlin Zhao · 9a09f15d · eabfc7d3
显示空白变更内容
内联并排

Showing with 6 addition and 4 deletion

source/libs/scalar/src/sclfunc.c source/libs/scalar/src/sclfunc.c +6 -4

未找到文件。
--- a/source/libs/scalar/src/sclfunc.c
+++ b/source/libs/scalar/src/sclfunc.c
@@ -1168,12 +1168,14 @@ int32_t timeDiffFunction(SScalarParam *pInput, int32_t inputNum, SScalarParam *p
        }
      }

+      if (pInput[k].numOfRows != 1) {
        if (IS_VAR_DATA_TYPE(type)) {
          input[k] += varDataTLen(input[k]);
        } else {
          input[k] += tDataTypes[type].bytes;
        }
      }
+    }

    int64_t result = (timeVal[0] >= timeVal[1]) ? (timeVal[0] - timeVal[1]) :
                                                  (timeVal[1] - timeVal[0]);