(iotdb) branch master updated: change next to nextWithTimer (#15071)

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 40dd0315408 change next to nextWithTimer (#15071)
40dd0315408 is described below

commit 40dd031540864611023f45750aadbc1be3195c4d
Author: Liao Lanyu <1435078...@qq.com>
AuthorDate: Wed Mar 12 18:04:35 2025 +0800

    change next to nextWithTimer (#15071)
---
 .../queryengine/execution/operator/process/AssignUniqueIdOperator.java  | 2 +-
 .../execution/operator/process/EnforceSingleRowOperator.java            | 2 +-
 .../execution/operator/process/window/TableWindowOperator.java          | 2 +-
 .../db/queryengine/execution/operator/sink/ShuffleHelperOperator.java   | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AssignUniqueIdOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AssignUniqueIdOperator.java
index 97a64293805..5501764482d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AssignUniqueIdOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AssignUniqueIdOperator.java
@@ -69,7 +69,7 @@ public class AssignUniqueIdOperator implements 
ProcessOperator {
 
   @Override
   public TsBlock next() throws Exception {
-    TsBlock tsBlock = child.next();
+    TsBlock tsBlock = child.nextWithTimer();
     if (tsBlock == null || tsBlock.isEmpty()) {
       return null;
     }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/EnforceSingleRowOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/EnforceSingleRowOperator.java
index bbc9b2c155c..9438d96dc30 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/EnforceSingleRowOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/EnforceSingleRowOperator.java
@@ -55,7 +55,7 @@ public class EnforceSingleRowOperator implements 
ProcessOperator {
 
   @Override
   public TsBlock next() throws Exception {
-    TsBlock tsBlock = child.next();
+    TsBlock tsBlock = child.nextWithTimer();
     if (tsBlock == null || tsBlock.isEmpty()) {
       return tsBlock;
     }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
index 62bf71eb585..ed1cbbcc481 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
@@ -150,7 +150,7 @@ public class TableWindowOperator implements ProcessOperator 
{
 
     if (inputOperator.hasNextWithTimer()) {
       // This TsBlock is pre-sorted with PARTITION BY and ORDER BY channels
-      TsBlock preSortedBlock = inputOperator.next();
+      TsBlock preSortedBlock = inputOperator.nextWithTimer();
       // StreamSort Operator sometimes returns null
       if (preSortedBlock == null || preSortedBlock.isEmpty()) {
         return null;
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/sink/ShuffleHelperOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/sink/ShuffleHelperOperator.java
index d5f6f13107a..36f076dfd26 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/sink/ShuffleHelperOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/sink/ShuffleHelperOperator.java
@@ -102,7 +102,7 @@ public class ShuffleHelperOperator implements Operator {
       needToReturnNull = false;
       return null;
     }
-    return children.get(downStreamChannelIndex.getCurrentIndex()).next();
+    return 
children.get(downStreamChannelIndex.getCurrentIndex()).nextWithTimer();
   }
 
   @Override