This is an automated email from the ASF dual-hosted git repository. zhihao pushed a commit to branch test/szh/add_more_tests_for_window_func in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 03b2d6c30fa8f712825da1869763fef85277adb9 Author: Sh-Zh-7 <[email protected]> AuthorDate: Fri Feb 20 22:24:25 2026 +0800 Add IT for new operators introduced by window function. --- .../execution/operator/process/ValuesOperatorTest.java | 9 +++------ .../operator/process/window/RowNumberOperatorTest.java | 6 ++---- .../operator/process/window/TopKRankingOperatorTest.java | 11 +++-------- 3 files changed, 8 insertions(+), 18 deletions(-) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/ValuesOperatorTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/ValuesOperatorTest.java index 61d0789e41c..cb5d9ea5c87 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/ValuesOperatorTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/ValuesOperatorTest.java @@ -51,8 +51,7 @@ import static org.junit.Assert.fail; public class ValuesOperatorTest { private static final ExecutorService instanceNotificationExecutor = - IoTDBThreadPoolFactory.newFixedThreadPool( - 1, "valuesOperator-test-instance-notification"); + IoTDBThreadPoolFactory.newFixedThreadPool(1, "valuesOperator-test-instance-notification"); @Test public void testEmptyValues() { @@ -103,8 +102,7 @@ public class ValuesOperatorTest { TsBlock block2 = createIntTsBlock(values2); TsBlock block3 = createIntTsBlock(values3); - try (ValuesOperator operator = - genValuesOperator(Arrays.asList(block1, block2, block3))) { + try (ValuesOperator operator = genValuesOperator(Arrays.asList(block1, block2, block3))) { assertFalse(operator.isFinished()); assertTrue(operator.hasNext()); @@ -202,8 +200,7 @@ public class ValuesOperatorTest { createFragmentInstanceContext(instanceId, stateMachine); DriverContext driverContext = new DriverContext(fragmentInstanceContext, 0); PlanNodeId planNode = new PlanNodeId("1"); - driverContext.addOperatorContext( - 1, planNode, TreeLinearFillOperator.class.getSimpleName()); + driverContext.addOperatorContext(1, planNode, TreeLinearFillOperator.class.getSimpleName()); return new ValuesOperator(driverContext.getOperatorContexts().get(0), tsBlocks); } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperatorTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperatorTest.java index 653b0cf3155..cdf58eb7681 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperatorTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperatorTest.java @@ -56,8 +56,7 @@ import static org.junit.Assert.fail; public class RowNumberOperatorTest { private static final ExecutorService instanceNotificationExecutor = - IoTDBThreadPoolFactory.newFixedThreadPool( - 1, "rowNumberOperator-test-instance-notification"); + IoTDBThreadPoolFactory.newFixedThreadPool(1, "rowNumberOperator-test-instance-notification"); @Test public void testRowNumberWithPartition() { @@ -248,8 +247,7 @@ public class RowNumberOperatorTest { createFragmentInstanceContext(instanceId, stateMachine); DriverContext driverContext = new DriverContext(fragmentInstanceContext, 0); PlanNodeId planNode = new PlanNodeId("1"); - driverContext.addOperatorContext( - 1, planNode, TreeLinearFillOperator.class.getSimpleName()); + driverContext.addOperatorContext(1, planNode, TreeLinearFillOperator.class.getSimpleName()); return driverContext; } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperatorTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperatorTest.java index 4c0bef0b44c..1bbf05f7679 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperatorTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperatorTest.java @@ -233,10 +233,7 @@ public class TopKRankingOperatorTest { int numColumns = tsBlock.getValueColumnCount(); for (int i = 0; i < tsBlock.getPositionCount(); i++, count++) { String device = - tsBlock - .getColumn(1) - .getBinary(i) - .getStringValue(TSFileConfig.STRING_CHARSET); + tsBlock.getColumn(1).getBinary(i).getStringValue(TSFileConfig.STRING_CHARSET); int value = tsBlock.getColumn(2).getInt(i); long rowNumber = tsBlock.getColumn(numColumns - 1).getLong(i); actualByDevice @@ -315,8 +312,7 @@ public class TopKRankingOperatorTest { } assertEquals(expectedTotalCount, count); for (int i = 0; i < expectedValueAndRn.length; i++) { - assertEquals( - "Value mismatch at row " + i, expectedValueAndRn[i][0], results.get(i)[0]); + assertEquals("Value mismatch at row " + i, expectedValueAndRn[i][0], results.get(i)[0]); assertEquals( "Row number mismatch at row " + i, expectedValueAndRn[i][1], results.get(i)[1]); } @@ -336,8 +332,7 @@ public class TopKRankingOperatorTest { createFragmentInstanceContext(instanceId, stateMachine); DriverContext driverContext = new DriverContext(fragmentInstanceContext, 0); PlanNodeId planNode = new PlanNodeId("1"); - driverContext.addOperatorContext( - 1, planNode, TreeLinearFillOperator.class.getSimpleName()); + driverContext.addOperatorContext(1, planNode, TreeLinearFillOperator.class.getSimpleName()); return driverContext; }
