save for poweroff

source/libs/function/inc/tudf.h

@@ -99,13 +99,16 @@ typedef struct SUdfInterBuf {
 
 // input: block, initFirst
 // output: interbuf
-int32_t callUdfAggProcess(SUdfDataBlock block, SUdfInterBuf *interBuf, bool initFirst);
+int32_t callUdfAggProcess(SUdfDataBlock *block, SUdfInterBuf *interBuf, bool initFirst);
 // input: interBuf
 // output: resultData
-int32_t callUdfAggFinalize(SUdfInterBuf interBuf, SUdfColumnData* resultData);
+int32_t callUdfAggFinalize(SUdfInterBuf *interBuf, SUdfColumnData *resultData);
+// input: interbuf1, interbuf2
+// output: resultBuf
+int32_t callUdfAggMerge(SUdfInterBuf *interBuf1, SUdfInterBuf *interBuf2, SUdfInterBuf *resultBuf);
 // input: block
 // output: resultData
-int32_t callUdfScalaProcess(SUdfDataBlock block, SUdfColumnData* resultData);
+int32_t callUdfScalaProcess(SUdfDataBlock *block, SUdfColumnData *resultData);
 
 /**
  * tearn down udf

source/libs/function/inc/tudfInt.h

@@ -31,6 +31,7 @@ enum {
 
 enum {
   TSDB_UDF_CALL_AGG_PROC = 0,
+  TSDB_UDF_CALL_AGG_MERGE,
   TSDb_UDF_CALL_AGG_FIN,
   TSDB_UDF_CALL_SCALA_PROC,
 };

source/libs/function/test/udf1.c

@@ -8,6 +8,7 @@
 #define malloc malloc
 #undef free
 #define free free
+
 int32_t udf1_setup() {
   return 0;
 }