refactor: do some internal refactor.

source/libs/scalar/src/sclvector.c

@@ -1543,8 +1543,10 @@ void vectorBitOr(SScalarParam *pLeft, SScalarParam *pRight, SScalarParam *pOut,
 int32_t doVectorCompareImpl(SScalarParam *pLeft, SScalarParam *pRight, SScalarParam *pOut, int32_t startIndex,
                             int32_t numOfRows, int32_t step, __compar_fn_t fp, int32_t optr) {
   int32_t num = 0;
+  bool *  pRes = (bool *)pOut->columnData;
 
-  for (int32_t i = startIndex; i < numOfRows && i >= 0; i += step) {
+  if (GET_PARAM_TYPE(pLeft) != TSDB_DATA_TYPE_JSON && GET_PARAM_TYPE(pRight) != TSDB_DATA_TYPE_JSON) {
+    for (int32_t i = startIndex; i < numOfRows && i >= startIndex; i += step) {
       int32_t leftIndex = (i >= pLeft->numOfRows) ? 0 : i;
       int32_t rightIndex = (i >= pRight->numOfRows) ? 0 : i;
 
@@ -1554,8 +1556,8 @@ int32_t doVectorCompareImpl(SScalarParam *pLeft, SScalarParam *pRight, SScalarPa
         continue;
       }
 
-    char   *pLeftData = colDataGetData(pLeft->columnData, leftIndex);
-    char   *pRightData = colDataGetData(pRight->columnData, rightIndex);
+      char *  pLeftData = colDataGetData(pLeft->columnData, leftIndex);
+      char *  pRightData = colDataGetData(pRight->columnData, rightIndex);
       int64_t leftOut = 0;
       int64_t rightOut = 0;
       bool    freeLeft = false;
@@ -1590,6 +1592,26 @@ int32_t doVectorCompareImpl(SScalarParam *pLeft, SScalarParam *pRight, SScalarPa
         taosMemoryFreeClear(pRightData);
       }
     }
+  } else {
+    for (int32_t i = startIndex; i < numOfRows && i >= 0; i += step) {
+      int32_t leftIndex = (i >= pLeft->numOfRows) ? 0 : i;
+      int32_t rightIndex = (i >= pRight->numOfRows) ? 0 : i;
+
+      if (colDataIsNull_f(pLeft->columnData->nullbitmap, leftIndex) ||
+          colDataIsNull_f(pRight->columnData->nullbitmap, rightIndex)) {
+        pRes[i] = false;
+        continue;
+      }
+
+      char *pLeftData = colDataGetData(pLeft->columnData, leftIndex);
+      char *pRightData = colDataGetData(pRight->columnData, rightIndex);
+
+      pRes[i] = filterDoCompare(fp, optr, pLeftData, pRightData);
+      if (pRes[i]) {
+        ++num;
+      }
+    }
+  }
 
   return num;
 }