feat(query): interp support return timestamp with pseudo column _irowts

TD-18842

source/libs/executor/src/timewindowoperator.c

@@ -2095,12 +2095,17 @@ static void genInterpolationResult(STimeSliceOperatorInfo* pSliceInfo, SExprSupp
   bool hasInterp = true;
   for (int32_t j = 0; j < pExprSup->numOfExprs; ++j) {
     SExprInfo* pExprInfo = &pExprSup->pExprInfo[j];
-    int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
-    int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
 
-    // SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
+    int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
     SColumnInfoData* pDst = taosArrayGet(pResBlock->pDataBlock, dstSlot);
 
+    if (IS_TIMESTAMP_TYPE(pExprInfo->base.resSchema.type)) {
+      colDataAppend(pDst, rows, (char*)&pSliceInfo->current, false);
+      continue;
+    }
+
+    int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
+    // SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
     switch (pSliceInfo->fillType) {
       case TSDB_FILL_NULL: {
         colDataAppendNULL(pDst, rows);
@@ -2346,19 +2351,24 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
       if (ts == pSliceInfo->current) {
         for (int32_t j = 0; j < pOperator->exprSupp.numOfExprs; ++j) {
           SExprInfo* pExprInfo = &pOperator->exprSupp.pExprInfo[j];
-          int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
-          int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
 
-          SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
+          int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
           SColumnInfoData* pDst = taosArrayGet(pResBlock->pDataBlock, dstSlot);
 
-          if (colDataIsNull_s(pSrc, i)) {
-            colDataAppendNULL(pDst, pResBlock->info.rows);
-            continue;
-          }
+          if (IS_TIMESTAMP_TYPE(pExprInfo->base.resSchema.type)) {
+            colDataAppend(pDst, pResBlock->info.rows, (char *)&pSliceInfo->current, false);
+          } else {
+            int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
+            SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
 
-          char* v = colDataGetData(pSrc, i);
-          colDataAppend(pDst, pResBlock->info.rows, v, false);
+            if (colDataIsNull_s(pSrc, i)) {
+              colDataAppendNULL(pDst, pResBlock->info.rows);
+              continue;
+            }
+
+            char* v = colDataGetData(pSrc, i);
+            colDataAppend(pDst, pResBlock->info.rows, v, false);
+          }
         }
 
         pResBlock->info.rows += 1;
@@ -2478,14 +2488,24 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
         if (ts == pSliceInfo->current && pSliceInfo->current <= pSliceInfo->win.ekey) {
           for (int32_t j = 0; j < pOperator->exprSupp.numOfExprs; ++j) {
             SExprInfo* pExprInfo = &pOperator->exprSupp.pExprInfo[j];
-            int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
-            int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
 
-            SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
+            int32_t    dstSlot = pExprInfo->base.resSchema.slotId;
             SColumnInfoData* pDst = taosArrayGet(pResBlock->pDataBlock, dstSlot);
 
-            char* v = colDataGetData(pSrc, i);
-            colDataAppend(pDst, pResBlock->info.rows, v, false);
+            if (IS_TIMESTAMP_TYPE(pExprInfo->base.resSchema.type)) {
+              colDataAppend(pDst, pResBlock->info.rows, (char *)&pSliceInfo->current, false);
+            } else {
+              int32_t    srcSlot = pExprInfo->base.pParam[0].pCol->slotId;
+              SColumnInfoData* pSrc = taosArrayGet(pBlock->pDataBlock, srcSlot);
+
+              if (colDataIsNull_s(pSrc, i)) {
+                colDataAppendNULL(pDst, pResBlock->info.rows);
+                continue;
+              }
+
+              char* v = colDataGetData(pSrc, i);
+              colDataAppend(pDst, pResBlock->info.rows, v, false);
+            }
           }
 
           pResBlock->info.rows += 1;