This is an automated email from the ASF dual-hosted git repository. weihao pushed a commit to branch addQueryDebug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0a80758eeddebf06beed463e39d643824ff8d696 Merge: 4640774700e 67fda53e0c1 Author: Weihao Li <[email protected]> AuthorDate: Fri Feb 6 14:11:30 2026 +0800 Merge branch 'master' of github.com:apache/iotdb into addQueryDebug Signed-off-by: Weihao Li <[email protected]> # Conflicts: # iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java .../IoTDBShowTimeseriesOrderByTimeseriesIT.java | 278 ++++++++ .../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 3 +- .../auto/basic/IoTDBTreePatternFormatIT.java | 58 ++ .../IoTDBPipeTsFileDecompositionWithModsIT.java | 316 +++++++++ ...tIT.java => IoTDBTablePreparedStatementIT.java} | 2 +- .../db/it/IoTDBTablePreparedStatementJDBCIT.java | 498 ++++++++++++++ .../org/apache/iotdb/jdbc/IoTDBConnection.java | 6 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 6 +- .../iotdb/jdbc/IoTDBTablePreparedStatement.java | 732 +++++++++++++++++++++ .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 142 ---- .../jdbc/IoTDBTablePreparedStatementTest.java | 240 +++++++ .../iotdb/rpc/stmt/PreparedParameterSerde.java | 175 +++++ .../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 127 ++++ iotdb-core/ainode/ainode.xml | 9 + iotdb-core/ainode/iotdb/ainode/core/config.py | 15 - iotdb-core/ainode/iotdb/ainode/core/constant.py | 1 - .../core/inference/inference_request_pool.py | 4 +- .../core/inference/pipeline/basic_pipeline.py | 74 ++- .../iotdb/ainode/core/inference/pool_controller.py | 13 +- .../ainode/iotdb/ainode/core/ingress/iotdb.py | 8 - .../iotdb/ainode/core/manager/inference_manager.py | 117 ++-- iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 3 +- .../ainode/resources/conf/iotdb-ainode.properties | 4 - .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +- .../iotdb/confignode/manager/ProcedureManager.java | 4 +- .../persistence/pipe/PipePluginInfo.java | 2 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 4 +- .../pipe/plugin/CreatePipePluginProcedure.java | 2 +- .../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +- .../scan/TsFileInsertionEventScanParser.java | 17 +- .../iotdb/db/protocol/thrift/OperationType.java | 5 +- .../impl/DataNodeInternalRPCServiceImpl.java | 16 +- .../thrift/impl/NativeStatementRequest.java | 99 +++ .../schema/source/LogicalViewSchemaSource.java | 3 +- .../schema/source/SchemaSourceFactory.java | 16 +- .../schema/source/TimeSeriesSchemaSource.java | 9 +- .../iotdb/db/queryengine/plan/Coordinator.java | 59 +- .../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +- .../config/executor/ClusterConfigTaskExecutor.java | 12 +- .../execution/config/session/DeallocateTask.java | 19 +- .../plan/execution/config/session/PrepareTask.java | 27 +- .../config/session/PreparedStatementHelper.java | 60 ++ .../db/queryengine/plan/parser/ASTVisitor.java | 10 + .../plan/planner/LogicalPlanBuilder.java | 8 +- .../plan/planner/LogicalPlanVisitor.java | 69 +- .../plan/planner/OperatorTreeGenerator.java | 3 +- .../SimpleFragmentParallelPlanner.java | 4 +- .../metadata/read/TimeSeriesSchemaScanNode.java | 49 +- .../node/process/ActiveRegionScanMergeNode.java | 3 + .../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +- .../plan/relational/planner/CteMaterializer.java | 2 +- ...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +- .../plan/statement/metadata/ShowStatement.java | 7 + .../metadata/ShowTimeSeriesStatement.java | 15 + .../apache/iotdb/db/schemaengine/SchemaEngine.java | 21 + .../schemaregion/impl/SchemaRegionMemoryImpl.java | 8 + .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 198 +++++- .../mtree/impl/mem/mnode/IMemMNode.java | 11 +- .../mtree/impl/mem/mnode/basic/BasicMNode.java | 16 +- .../impl/mem/mnode/impl/AboveDatabaseMNode.java | 10 + .../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 10 + .../impl/mem/mnode/impl/MeasurementMNode.java | 10 + .../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 148 +++++ .../schemaregion/read/req/IShowTimeSeriesPlan.java | 4 + .../read/req/SchemaRegionReadPlanFactory.java | 14 +- .../read/req/impl/ShowTimeSeriesPlanImpl.java | 18 +- .../impl/SchemaReaderLimitOffsetWrapper.java | 36 +- .../template/ClusterTemplateManager.java | 8 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 1 + .../schemaRegion/SchemaRegionTestUtil.java | 25 +- .../db/pipe/pattern/TreePatternPruningTest.java | 20 + .../schema/SchemaQueryScanOperatorTest.java | 3 +- .../task/subtask/PipeAbstractSinkSubtask.java | 11 +- .../pipe/datastructure/pattern/TreePattern.java | 28 +- .../thrift-ainode/src/main/thrift/ainode.thrift | 3 +- .../thrift-datanode/src/main/thrift/client.thrift | 35 + scripts/sbin/start-ainode.sh | 2 +- scripts/sbin/stop-ainode.sh | 2 +- .../ops/{daemon-datanode.sh => daemon-ainode.sh} | 28 +- scripts/tools/ops/daemon-confignode.sh | 3 +- scripts/tools/ops/daemon-datanode.sh | 3 +- 81 files changed, 3620 insertions(+), 430 deletions(-)
