This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch showConfigurationSQL in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 62aa4d6f79e458556fcaf93ff5eab9ab1af88191 Merge: ccb68fef9a7 0a2166fab5b Author: shuwenwei <[email protected]> AuthorDate: Thu Aug 28 21:57:54 2025 +0800 Merge branch 'master' into showConfigurationSQL example/client-cpp-example/pom.xml | 4 + example/client-cpp-example/src/CMakeLists.txt | 5 +- .../client-cpp-example/src}/MultiSvrNodeClient.cpp | 0 .../it/env/cluster/config/MppCommonConfig.java | 6 - .../env/cluster/config/MppSharedCommonConfig.java | 7 - .../it/env/remote/config/RemoteCommonConfig.java | 5 - .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 - .../org/apache/iotdb/db/it/utils/TestUtils.java | 65 ++ .../relational/it/db/it/IoTDBWindowTVFIT.java | 283 ++++++++- .../scalar/IoTDBCastFunctionTableIT.java | 1 + .../scalar/IoTDBFormatFunctionTableIT.java | 1 + .../it/query/old/query/IoTDBArithmeticTableIT.java | 1 + .../relational/it/query/recent/IoTDBCteIT.java | 332 ++++++++++ .../view/old/query/IoTDBArithmeticTableViewIT.java | 1 + .../org/apache/iotdb/tool/common/Constants.java | 12 +- .../org/apache/iotdb/tool/common/OptionsUtil.java | 59 +- .../apache/iotdb/tool/data/AbstractDataTool.java | 4 +- .../org/apache/iotdb/tool/data/ExportData.java | 8 +- .../apache/iotdb/tool/data/ExportDataTable.java | 124 ++-- .../org/apache/iotdb/tool/data/ExportDataTree.java | 166 +++-- .../org/apache/iotdb/tool/data/ImportData.java | 20 +- .../apache/iotdb/tool/data/ImportDataTable.java | 94 +-- iotdb-client/client-cpp/src/main/CMakeLists.txt | 5 + iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 4 +- iotdb-client/client-cpp/src/main/Session.cpp | 6 +- iotdb-client/client-cpp/src/main/SessionBuilder.h | 2 +- iotdb-client/client-cpp/src/test/CMakeLists.txt | 5 + iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 29 +- .../response/pipe/task/PipeTableResp.java | 11 +- .../agent/runtime/PipeConfigNodeRuntimeAgent.java | 11 +- .../pipe/agent/task/PipeConfigNodeSubtask.java | 51 +- .../pipe/agent/task/PipeConfigNodeTaskAgent.java | 11 +- .../pipe/agent/task/PipeConfigNodeTaskBuilder.java | 6 +- .../PipeConfigPhysicalPlanTSStatusVisitor.java | 1 + .../sink/protocol/IoTDBConfigRegionAirGapSink.java | 5 + .../pipe/sink/protocol/IoTDBConfigRegionSink.java | 5 + .../pipe/source/IoTDBConfigRegionSource.java | 2 +- .../confignode/persistence/pipe/PipeInfo.java | 10 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 16 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 4 +- .../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 4 +- .../pipe/util/PipeExternalSourceLoadBalancer.java | 2 +- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 63 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 19 +- .../agent/task/builder/PipeDataNodeBuilder.java | 2 +- .../task/builder/PipeDataNodeTaskBuilder.java | 72 ++- .../pipe/agent/task/stage/PipeTaskSourceStage.java | 9 +- .../agent/task/subtask/sink/PipeSinkSubtask.java | 66 +- .../task/subtask/sink/PipeSinkSubtaskManager.java | 6 +- .../pipe/metric/overview/PipeResourceMetrics.java | 13 + .../protocol/airgap/IoTDBDataRegionAirGapSink.java | 31 + .../airgap/IoTDBSchemaRegionAirGapSink.java | 5 + .../thrift/async/IoTDBDataRegionAsyncSink.java | 14 + .../async/handler/PipeTransferTsFileHandler.java | 6 + .../thrift/sync/IoTDBDataRegionSyncSink.java | 21 + .../thrift/sync/IoTDBSchemaRegionSink.java | 5 + .../source/dataregion/IoTDBDataRegionSource.java | 10 +- ...istoricalDataRegionTsFileAndDeletionSource.java | 6 +- .../PipeRealtimeDataRegionHybridSource.java | 1 + .../realtime/PipeRealtimeDataRegionLogSource.java | 1 + .../realtime/PipeRealtimeDataRegionSource.java | 21 +- .../PipeRealtimeDataRegionTsFileSource.java | 2 + .../dataregion/realtime/epoch/TsFileEpoch.java | 28 +- .../realtime/epoch/TsFileEpochManager.java | 3 - .../db/pipe/source/mqtt/MQTTPublishHandler.java | 4 +- .../iotdb/db/pipe/source/mqtt/MQTTSource.java | 6 +- .../config/executor/ClusterConfigTaskExecutor.java | 14 +- .../plan/planner/plan/node/PlanGraphPrinter.java | 7 +- .../relational/analyzer/StatementAnalyzer.java | 15 +- .../function/TableBuiltinTableFunction.java | 6 +- .../function/tvf/PatternMatchTableFunction.java | 266 ++++++++ .../function/tvf/match/MatchConfig.java} | 23 +- .../function/tvf/match/QetchAlgorithm.java | 683 +++++++++++++++++++++ .../function/tvf/match/model/MatchState.java | 233 +++++++ .../function/tvf/match/model/PatternSegment.java | 285 +++++++++ .../function/tvf/match/model/Point.java} | 27 +- .../function/tvf/match/model/RegexMatchState.java | 396 ++++++++++++ .../function/tvf/match/model/Section.java | 238 +++++++ .../plan/relational/planner/RelationPlanner.java | 23 + .../scalar/DateBinFunctionColumnTransformer.java | 21 +- .../column/unary/scalar/ExtractTransformer.java | 12 +- .../java/org/apache/iotdb/db/service/DataNode.java | 4 + .../iotdb/db/service/DataNodeShutdownHook.java | 4 + .../load/limiter/LoadTsFileRateLimiter.java | 64 +- .../memory/LoadTsFileDataCacheMemoryBlock.java | 3 +- .../load/memory/LoadTsFileMemoryBlock.java | 3 +- .../subtask/SubscriptionSinkSubtaskManager.java | 2 +- .../org/apache/iotdb/db/utils/DateTimeUtils.java | 75 ++- .../agent/plugin/PipeDataNodePluginAgentTest.java | 4 +- .../db/pipe/consensus/DeletionResourceTest.java | 4 +- .../pattern/CachedSchemaPatternMatcherTest.java | 9 +- .../db/pipe/source/PipeRealtimeExtractTest.java | 10 +- .../relational/analyzer/ExtractExpressionTest.java | 7 + .../apache/iotdb/commons/conf/CommonConfig.java | 28 + .../iotdb/commons/conf/CommonDescriptor.java | 2 + .../commons/pipe/agent/plugin/PipePluginAgent.java | 8 +- .../commons/pipe/agent/task/PipeTaskAgent.java | 14 +- .../pipe/agent/task/meta/PipeStaticMeta.java | 58 +- .../task/subtask/PipeAbstractSinkSubtask.java | 16 +- .../iotdb/commons/pipe/config/PipeConfig.java | 6 + .../iotdb/commons/pipe/config/PipeDescriptor.java | 6 + .../pipe/config/constant/PipeSinkConstant.java | 5 + ....java => PipeTaskSourceRuntimeEnvironment.java} | 9 +- .../limiter/GlobalRPCRateLimiter.java} | 20 +- .../pipe/sink/limiter/GlobalRateLimiter.java | 14 +- .../limiter/TsFileSendRateLimiter.java} | 30 +- .../pipe/sink/protocol/IoTDBAirGapSink.java | 3 + .../commons/pipe/sink/protocol/IoTDBSink.java | 4 +- .../pipe/sink/protocol/IoTDBSslSyncSink.java | 3 + .../iotdb/commons/pipe/source/IoTDBSource.java | 6 +- .../iotdb/commons/service/metric/enums/Metric.java | 1 + .../iotdb/library/match/PatternExecutor.java | 9 +- 113 files changed, 3808 insertions(+), 680 deletions(-)
