This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch Wal_mem_control in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3fc62917874e90b469b9a3a6b74c7b58a3e405b6 Merge: 0eb13b7d2c8 06d9f3bb963 Author: HTHou <[email protected]> AuthorDate: Thu Dec 5 09:41:18 2024 +0800 Merge branch 'master' of github.com:apache/iotdb into Wal_mem_control .github/workflows/vulnerability-check.yml | 4 +- .../src/AlignedTimeseriesSessionExample.cpp | 30 +- example/client-cpp-example/src/SessionExample.cpp | 20 +- .../src/TableModelSessionExample.cpp | 212 +++++++++ ...onMigrateDataNodeCrashITFrameworkForIoTV1.java} | 17 +- ...onMigrateDataNodeCrashITFrameworkForIoTV2.java} | 3 +- .../IoTDBRegionMigrateReliabilityITFramework.java | 3 +- .../{ => commit}/IoTDBRegionMigrateNormalIT.java | 2 +- .../{ => commit}/IoTDBRegionMigrateOtherIT.java | 2 +- ...inatorCrashWhenRemoveRemotePeerForIoTV1IT.java} | 15 +- ...IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java} | 18 +- ...riginalCrashWhenDeleteLocalPeerForIoTV1IT.java} | 8 +- ...iginalCrashWhenRemoveRemotePeerForIoTV1IT.java} | 8 +- ...inatorCrashWhenRemoveRemotePeerForIoTV2IT.java} | 15 +- ...IoTDBRegionMigrateDataNodeCrashForIoTV2IT.java} | 17 +- ...riginalCrashWhenDeleteLocalPeerForIoTV2IT.java} | 8 +- ...iginalCrashWhenRemoveRemotePeerForIoTV2IT.java} | 8 +- .../IoTDBRegionMigrateClusterCrashIoTV1IT.java} | 18 +- .../IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java} | 19 +- .../IoTDBRegionMigrateClusterCrashIoTV2IT.java} | 5 +- .../IoTDBRegionMigrateConfigNodeCrashIoTV2IT.java} | 5 +- .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 55 +++ .../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 2 +- iotdb-client/client-cpp/pom.xml | 16 + .../client-cpp/src/main/AbstractSessionBuilder.h | 25 +- iotdb-client/client-cpp/src/main/Session.cpp | 110 +++-- iotdb-client/client-cpp/src/main/Session.h | 173 ++++++- iotdb-client/client-cpp/src/main/TableSession.cpp | 44 ++ .../client-cpp/src/main/TableSession.h | 31 +- .../client-cpp/src/main/TableSessionBuilder.h | 76 ++++ iotdb-client/client-cpp/src/test/CMakeLists.txt | 9 + iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 2 +- .../src/test/cpp/sessionRelationalIT.cpp | 117 +++++ .../client-cpp/src/test/main_Relational.cpp | 34 +- .../iotdb/rpc/subscription/config/TopicConfig.java | 80 +++- .../rpc/subscription/config/TopicConstant.java | 8 + .../session/subscription/SubscriptionSession.java | 26 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +- iotdb-core/confignode/pom.xml | 6 + .../confignode/conf/ConfigNodeDescriptor.java | 18 +- .../confignode/conf/ConfigNodeStartupCheck.java | 2 +- .../write/template/CreateSchemaTemplatePlan.java | 14 +- .../iotdb/confignode/manager/ConfigManager.java | 4 +- .../persistence/schema/ClusterSchemaInfo.java | 4 +- .../persistence/schema/TemplateTable.java | 4 +- .../confignode/procedure/ProcedureExecutor.java | 109 +++-- .../procedure/env/RegionMaintainHandler.java | 27 +- .../procedure/impl/node/AbstractNodeProcedure.java | 5 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 9 +- .../impl/region/AddRegionPeerProcedure.java | 5 +- .../confignode/conf/ConfigNodePropertiesTest.java | 50 ++ .../apache/iotdb/consensus/pipe/PipeConsensus.java | 6 +- .../consensus/pipe/PipeConsensusServerImpl.java | 17 +- .../service/PipeConsensusRPCServiceProcessor.java | 12 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 72 +-- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 11 +- .../db/conf/rest/IoTDBRestServiceDescriptor.java | 49 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 15 +- .../connector/protocol/opcua/OpcUaConnector.java | 27 +- .../connector/protocol/opcua/OpcUaNameSpace.java | 202 +++++++-- .../consensus/ConsensusPipeDataNodeDispatcher.java | 8 +- .../dataregion/IoTDBDataRegionExtractor.java | 2 + .../PipeDataNodeRemainingEventAndTimeMetrics.java | 14 + .../iotdb/db/queryengine/plan/Coordinator.java | 15 +- .../plan/execution/config/ConfigExecution.java | 53 ++- .../execution/config/TableConfigTaskVisitor.java | 78 +++- .../execution/config/TreeConfigTaskVisitor.java | 19 +- .../config/executor/ClusterConfigTaskExecutor.java | 501 ++++++++------------- .../config/executor/IConfigTaskExecutor.java | 4 +- .../config/metadata/relational/ShowDBTask.java | 28 +- .../config/sys/subscription/CreateTopicTask.java | 12 +- .../config/sys/subscription/DropTopicTask.java | 11 +- ...riptionTask.java => ShowSubscriptionsTask.java} | 17 +- .../config/sys/subscription/ShowTopicsTask.java | 12 +- .../plan/relational/analyzer/Analyzer.java | 11 - .../relational/analyzer/StatementAnalyzer.java | 57 +-- .../plan/relational/planner/TableModelPlanner.java | 9 +- .../plan/relational/security/AccessControl.java | 113 ++++- .../relational/security/AccessControlImpl.java | 91 ++++ .../relational/security/AllowAllAccessControl.java | 64 ++- .../relational/security/ITableAuthChecker.java | 76 ++++ ...AccessControl.java => TableModelPrivilege.java} | 15 +- .../plan/relational/sql/ast/AstVisitor.java | 16 + .../plan/relational/sql/ast/CreateTopic.java | 87 ++++ .../plan/relational/sql/ast/DropTopic.java | 75 +++ .../plan/relational/sql/ast/ShowSubscriptions.java | 66 +++ .../plan/relational/sql/ast/ShowTopics.java | 66 +++ .../ast/SubscriptionStatement.java} | 18 +- .../plan/relational/sql/parser/AstBuilder.java | 57 ++- .../plan/relational/sql/util/SqlFormatter.java | 70 +++ .../queryengine/plan/statement/StatementType.java | 2 +- .../metadata/subscription/DropTopicStatement.java | 1 + .../iotdb/db/storageengine/StorageEngine.java | 4 +- .../dataregion/wal/utils/WALEntryHandler.java | 5 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +- .../iotdb/db/{utils => conf}/PropertiesTest.java | 35 +- .../plan/relational/analyzer/AnalyzerTest.java | 5 +- .../plan/relational/analyzer/AuthTest.java | 252 +++++++++++ .../plan/relational/planner/PlanTester.java | 6 +- .../iotdb/db/utils/ConfigurationFileUtilsTest.java | 80 ++++ .../metrics/config/MetricConfigDescriptor.java | 6 +- .../iotdb/commons/conf/CommonDescriptor.java | 9 +- .../iotdb/commons/conf/ConfigurationFileUtils.java | 2 +- .../apache/iotdb/commons/conf/TrimProperties.java | 34 +- .../exception/auth/AccessDeniedException.java} | 14 +- .../task/progress/PipeEventCommitManager.java | 26 +- .../config/constant/PipeConnectorConstant.java | 4 + .../configuraion/PipeTaskRuntimeConfiguration.java | 2 +- .../commons/subscription/meta/topic/TopicMeta.java | 19 +- .../db/relational/grammar/sql/RelationalSql.g4 | 38 +- .../src/main/thrift/pipeconsensus.thrift | 1 + 111 files changed, 3255 insertions(+), 879 deletions(-)
