This is an automated email from the ASF dual-hosted git repository. chenyz pushed a commit to branch parallel_multi_child_node in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 786f907e30fd48d74d9a629a9e5af739f61238bc Author: Chen YZ <[email protected]> AuthorDate: Mon Feb 24 18:04:17 2025 +0800 update example --- .../plan/relational/planner/ExampleTest.java | 32 +++++++--------------- 1 file changed, 10 insertions(+), 22 deletions(-) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ExampleTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ExampleTest.java index fe67612153e..9aa77ee24d5 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ExampleTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ExampleTest.java @@ -121,19 +121,13 @@ public class ExampleTest { * └──OffsetNode-6 * └──ProjectNode * └──MergeSortNode-25 - * ├──ExchangeNode-29: [SourceAddress:192.0.12.1/test_query.2.0/31] - * ├──SortNode-27 - * │ └──ProjectNode-23 - * │ └──FilterNode-17 - * │ └──TableScanNode-14 - * └──ExchangeNode-30: [SourceAddress:192.0.10.1/test_query.3.0/32] + * ├──ExchangeNode-28: [SourceAddress:192.0.10.1/test_query.2.0/30] + * ├──ExchangeNode-29: [SourceAddress:192.0.11.1/test_query.3.0/31] + * └──ExchangeNode-30: [SourceAddress:192.0.12.1/test_query.4.0/32] */ assertPlan( planTester.getFragmentPlan(0), - anyTree( - project( - mergeSort( - exchange(), sort(project(filter(filterPredicate, tableScan))), exchange())))); + anyTree(project(mergeSort(exchange(), exchange(), exchange())))); /* * SortNode-26 @@ -141,17 +135,11 @@ public class ExampleTest { * └──FilterNode-16 * └──TableScanNode-13 */ - assertPlan( - planTester.getFragmentPlan(1), - any( // use any() to match any one node - project(filter(filterPredicate, tableScan)))); - - /* - * SortNode-26 - * └──ProjectNode-19 - * └──FilterNode-16 - * └──TableScanNode-13 - */ - assertPlan(planTester.getFragmentPlan(2), any(project(filter(filterPredicate, tableScan)))); + for (int i = 1; i <= 3; i++) { + assertPlan( + planTester.getFragmentPlan(i), + any( // use any() to match any one node + project(filter(filterPredicate, tableScan)))); + } } }
