This is an automated email from the ASF dual-hosted git repository. lancelly pushed a commit to branch operatorNext in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 52cf2d3d6a20793abe0d6378ce0455d2e12094c0 Author: lancelly <[email protected]> AuthorDate: Wed Mar 12 17:19:37 2025 +0800 change next to nextWithTimer --- .../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
