From c1666e7e0276e2894e7ee60bf93be080e4d4f518 Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <ganlinzhao@hotmail.com>
Date: Fri, 13 May 2022 21:13:35 +0800
Subject: [PATCH] feat(query): add sample function

---
 source/libs/function/src/builtins.c     |  2 +-
 source/libs/function/src/builtinsimpl.c | 32 ++++++++++++-------------
 2 files changed, 17 insertions(+), 17 deletions(-)

diff --git a/source/libs/function/src/builtins.c b/source/libs/function/src/builtins.c
index 202e7f9675..53e480a4c4 100644
--- a/source/libs/function/src/builtins.c
+++ b/source/libs/function/src/builtins.c
@@ -848,7 +848,7 @@ const SBuiltinFuncDefinition funcMgtBuiltins[] = {
     .getEnvFunc   = getSampleFuncEnv,
     .initFunc     = sampleFunctionSetup,
     .processFunc  = sampleFunction,
-    .finalizeFunc = sampleFinalize
+    .finalizeFunc = NULL
   },
   {
     .name = "abs",
diff --git a/source/libs/function/src/builtinsimpl.c b/source/libs/function/src/builtinsimpl.c
index 0b2ee9b749..42602166f1 100644
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -3124,19 +3124,19 @@ int32_t sampleFunction(SqlFunctionCtx* pCtx) {
   return pInfo->numSampled;
 }
 
-int32_t sampleFinalize(SqlFunctionCtx* pCtx, SSDataBlock* pBlock) {
-  SResultRowEntryInfo* pResInfo = GET_RES_INFO(pCtx);
-  SSampleInfo* pInfo = GET_ROWCELL_INTERBUF(GET_RES_INFO(pCtx));
-  int32_t        slotId = pCtx->pExpr->base.resSchema.slotId;
-  SColumnInfoData* pCol = taosArrayGet(pBlock->pDataBlock, slotId);
-
-  //int32_t currentRow = pBlock->info.rows;
-  pResInfo->numOfRes = pInfo->numSampled;
-
-  for (int32_t i = 0; i < pInfo->numSampled; ++i) {
-    colDataAppend(pCol, i, pInfo->data + i * pInfo->colBytes, false);
-    //TODO: handle ts output
-  }
-
-  return pResInfo->numOfRes;
-}
+//int32_t sampleFinalize(SqlFunctionCtx* pCtx, SSDataBlock* pBlock) {
+//  SResultRowEntryInfo* pResInfo = GET_RES_INFO(pCtx);
+//  SSampleInfo* pInfo = GET_ROWCELL_INTERBUF(GET_RES_INFO(pCtx));
+//  int32_t        slotId = pCtx->pExpr->base.resSchema.slotId;
+//  SColumnInfoData* pCol = taosArrayGet(pBlock->pDataBlock, slotId);
+//
+//  //int32_t currentRow = pBlock->info.rows;
+//  pResInfo->numOfRes = pInfo->numSampled;
+//
+//  for (int32_t i = 0; i < pInfo->numSampled; ++i) {
+//    colDataAppend(pCol, i, pInfo->data + i * pInfo->colBytes, false);
+//    //TODO: handle ts output
+//  }
+//
+//  return pResInfo->numOfRes;
+//}
-- 
GitLab