refactor: do some internal refactor.

source/libs/function/src/builtinsimpl.c

@@ -789,11 +789,37 @@ int32_t minmaxFunctionFinalize(SqlFunctionCtx* pCtx, SSDataBlock* pBlock) {
   SColumnInfoData* pCol = taosArrayGet(pBlock->pDataBlock, slotId);
   pEntryInfo->isNullRes = (pEntryInfo->numOfRes == 0) ? 1 : 0;
 
-  if (pCol->info.type == TSDB_DATA_TYPE_FLOAT) {
-    float v = GET_FLOAT_VAL(&pRes->v);
-    colDataAppend(pCol, currentRow, (const char*)&v, pEntryInfo->isNullRes);
+  // NOTE: do nothing change it, for performance issue
+  if (!pEntryInfo->isNullRes) {
+    switch (pCol->info.type) {
+      case TSDB_DATA_TYPE_UBIGINT:
+      case TSDB_DATA_TYPE_BIGINT:
+        colDataAppendInt64(pCol, currentRow, &pRes->v);
+        break;
+      case TSDB_DATA_TYPE_UINT:
+      case TSDB_DATA_TYPE_INT:
+        colDataAppendInt32(pCol, currentRow, (int32_t*)&pRes->v);
+        break;
+      case TSDB_DATA_TYPE_USMALLINT:
+      case TSDB_DATA_TYPE_SMALLINT:
+        colDataAppendInt16(pCol, currentRow, (int16_t*)&pRes->v);
+        break;
+      case TSDB_DATA_TYPE_BOOL:
+      case TSDB_DATA_TYPE_UTINYINT:
+      case TSDB_DATA_TYPE_TINYINT:
+        colDataAppendInt8(pCol, currentRow, (int8_t*)&pRes->v);
+        break;
+      case TSDB_DATA_TYPE_DOUBLE:
+        colDataAppendDouble(pCol, currentRow, (double*)&pRes->v);
+        break;
+      case TSDB_DATA_TYPE_FLOAT: {
+        float v = GET_FLOAT_VAL(&pRes->v);
+        colDataAppendFloat(pCol, currentRow, &v);
+        break;
+      }
+    }
   } else {
-    colDataAppend(pCol, currentRow, (const char*)&pRes->v, pEntryInfo->isNullRes);
+    colDataAppendNULL(pCol, currentRow);
   }
 
   if (pEntryInfo->numOfRes > 0) {
@@ -1674,11 +1700,6 @@ int32_t percentileFinalize(SqlFunctionCtx* pCtx, SSDataBlock* pBlock) {
   }
 
   tMemBucketDestroy(pMemBucket);
-
-  if (ppInfo->result < 0) {
-    return TSDB_CODE_NO_AVAIL_DISK;
-  }
-
   return functionFinalize(pCtx, pBlock);
 }
 

source/libs/function/src/detail/tminmax.c

@@ -836,7 +836,35 @@ int32_t doMinMaxHelper(SqlFunctionCtx* pCtx, int32_t isMinFunc, int32_t* nElems)
     int32_t i = findFirstValPosition(pCol, start, numOfRows);
 
     if ((i < end) && (!pBuf->assign)) {
-      memcpy(&pBuf->v, pCol->pData + (pCol->info.bytes * i), pCol->info.bytes);
+      char* p = pCol->pData + pCol->info.bytes * i;
+
+      switch (pCol->info.type) {
+        case TSDB_DATA_TYPE_DOUBLE:
+        case TSDB_DATA_TYPE_UBIGINT:
+        case TSDB_DATA_TYPE_BIGINT:
+          pBuf->v = *(int64_t*)p;
+          break;
+        case TSDB_DATA_TYPE_UINT:
+        case TSDB_DATA_TYPE_INT:
+          pBuf->v = *(int32_t*)p;
+          break;
+        case TSDB_DATA_TYPE_USMALLINT:
+        case TSDB_DATA_TYPE_SMALLINT:
+          pBuf->v = *(int16_t*)p;
+          break;
+        case TSDB_DATA_TYPE_BOOL:
+        case TSDB_DATA_TYPE_UTINYINT:
+        case TSDB_DATA_TYPE_TINYINT:
+          pBuf->v = *(int8_t*)p;
+          break;
+        case TSDB_DATA_TYPE_FLOAT: {
+          *(float*)&pBuf->v = *(float*)p;
+          break;
+        }
+        default:
+          memcpy(&pBuf->v, p, pCol->info.bytes);
+          break;
+      }
 
       if (pCtx->subsidiaries.num > 0) {
         int32_t code = saveTupleData(pCtx, i, pCtx->pSrcBlock, &pBuf->tuplePos);