This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch optimize in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 32fcf8b18f44603cfd080c292ae6accf0a9dcd50 Merge: 13f72c8b009 bcb18d24a01 Author: Beyyes <[email protected]> AuthorDate: Sat Mar 15 11:41:03 2025 +0800 Merge branch 'master' of github.com:apache/iotdb .../scalar/IoTDBFormatFunctionTableIT.java | 2 +- .../it/query/old/query/IoTDBArithmeticTableIT.java | 12 + .../it/query/recent/IoTDBColumnsMatchTableIT.java | 354 ++++++++ .../IoTDBDefaultPullConsumerDataSetIT.java | 28 +- ...sensusRetryWithIncreasingIntervalException.java | 15 +- .../load/cache/detector/PhiAccrualDetector.java | 4 +- .../load/cache/node/AINodeHeartbeatCache.java | 35 +- .../load/cache/node/ConfigNodeHeartbeatCache.java | 24 +- .../load/cache/node/DataNodeHeartbeatCache.java | 37 +- .../manager/load/cache/region/RegionCache.java | 24 +- .../consensus/iot/client/DispatchLogHandler.java | 27 +- .../ArithmeticBinaryColumnTransformer.ftl | 11 + .../async/handler/PipeTransferTsFileHandler.java | 15 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 4 +- .../db/pipe/resource/memory/PipeMemoryManager.java | 31 +- .../pipe/resource/tsfile/PipeTsFileResource.java | 6 +- .../impl/DataNodeInternalRPCServiceImpl.java | 57 +- .../db/queryengine/execution/driver/Driver.java | 15 +- .../execution/exchange/SharedTsBlockQueue.java | 11 + .../execution/exchange/sink/ISinkChannel.java | 2 + .../execution/exchange/sink/LocalSinkChannel.java | 21 +- .../execution/exchange/sink/ShuffleSinkHandle.java | 3 + .../execution/exchange/sink/SinkChannel.java | 3 +- .../exchange/source/LocalSourceHandle.java | 12 +- .../fragment/FragmentInstanceContext.java | 28 +- .../fragment/FragmentInstanceExecution.java | 18 +- .../fragment/FragmentInstanceManager.java | 24 +- .../operator/process/CollectOperator.java | 7 + .../relational/AbstractMergeSortJoinOperator.java | 4 +- .../execution/schedule/AbstractDriverThread.java | 27 +- .../execution/schedule/DriverScheduler.java | 2 +- .../plan/analyze/ClusterPartitionFetcher.java | 5 - .../plan/analyze/IPartitionFetcher.java | 4 - .../queryengine/plan/execution/QueryExecution.java | 5 + .../plan/planner/TableOperatorGenerator.java | 3 + .../SimpleFragmentParallelPlanner.java | 2 +- .../plan/planner/plan/PlanFragment.java | 22 +- .../relational/analyzer/ExpressionAnalyzer.java | 6 + .../relational/analyzer/StatementAnalyzer.java | 910 ++++++++++++++++++++- .../relational/metadata/TableMetadataImpl.java | 2 +- .../relational/planner/TableLogicalPlanner.java | 13 +- .../planner/distribute/AddExchangeNodes.java | 23 +- .../distribute/TableDistributedPlanner.java | 12 +- .../distribute/TableModelQueryFragmentPlanner.java | 17 +- .../plan/relational/planner/node/ExchangeNode.java | 6 +- .../plan/relational/planner/node/OutputNode.java | 2 + .../plan/relational/sql/ast/AstVisitor.java | 4 + .../plan/relational/sql/ast/Columns.java | 96 +++ .../plan/relational/sql/ast/SingleColumn.java | 21 + .../queryengine/plan/relational/sql/ast/Trim.java | 2 +- .../plan/relational/sql/parser/AstBuilder.java | 11 + .../relational/sql/util/ExpressionFormatter.java | 6 + .../scheduler/load/LoadTsFileDispatcherImpl.java | 27 +- .../plan/scheduler/load/LoadTsFileScheduler.java | 24 +- .../dataregion/wal/utils/WALEntryHandler.java | 4 +- .../dataregion/wal/utils/WALInsertNodeCache.java | 10 +- .../db/utils/datastructure/AlignedTVList.java | 10 +- .../plan/analyze/FakePartitionFetcherImpl.java | 5 - .../plan/planner/distribution/Util.java | 5 - .../plan/planner/distribution/Util2.java | 5 - .../plan/relational/analyzer/AggregationTest.java | 305 +++---- .../plan/relational/analyzer/AnalyzerTest.java | 142 ++-- .../plan/relational/analyzer/DistinctTest.java | 48 +- .../plan/relational/analyzer/JoinTest.java | 94 ++- .../analyzer/LimitOffsetPushDownTest.java | 183 ++--- .../analyzer/MockTableModelDataPartition.java | 9 + .../plan/relational/analyzer/SortTest.java | 288 +++---- .../plan/relational/analyzer/SubQueryTest.java | 44 +- .../plan/relational/analyzer/TSBSMetadata.java | 7 - .../relational/analyzer/TableFunctionTest.java | 56 +- .../plan/relational/analyzer/TestMatadata.java | 7 - .../plan/relational/analyzer/TestUtils.java | 26 + .../plan/relational/analyzer/TreeViewTest.java | 72 +- .../plan/relational/planner/ExampleTest.java | 34 +- .../planner/UncorrelatedSubqueryTest.java | 164 ++-- .../planner/assertions/ExchangeNodeMatcher.java | 8 +- .../planner/assertions/PlanMatchPattern.java | 4 - .../planner/assertions/PlanMatchingVisitor.java | 12 +- .../dataregion/memtable/TsFileProcessorTest.java | 28 +- .../task/subtask/PipeAbstractConnectorSubtask.java | 4 +- .../agent/task/subtask/PipeReportableSubtask.java | 13 +- .../pipe/receiver/PipeReceiverStatusHandler.java | 8 + .../org/apache/iotdb/commons/utils/RetryUtils.java | 8 + .../db/relational/grammar/sql/RelationalSql.g4 | 1 + .../src/main/thrift/datanode.thrift | 1 - 85 files changed, 2454 insertions(+), 1237 deletions(-)
