This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch last_cache in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 32ddc7eff5088b1924482b3ab3fd0a9b6012b7bc Merge: b4223729970 a4065454b45 Author: Beyyes <[email protected]> AuthorDate: Tue Oct 29 10:46:03 2024 +0800 Merge branch 'master' into last_cache .../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 45 ++++ .../org/apache/iotdb/db/it/utils/TestUtils.java | 43 +++ .../it/query/recent/IoTDBNullIdQueryIT.java | 40 +++ .../iotdb/rpc/subscription/config/TopicConfig.java | 7 +- .../payload/poll/SubscriptionPollResponse.java | 20 +- .../iotdb/confignode/manager/ProcedureManager.java | 14 +- .../subscription/SubscriptionMetaSyncer.java | 38 +-- .../persistence/subscription/SubscriptionInfo.java | 15 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 18 +- .../impl/pipe/runtime/PipeMetaSyncProcedure.java | 3 +- .../AbstractOperateSubscriptionProcedure.java | 42 ++- .../consumer/AlterConsumerGroupProcedure.java | 60 ++--- .../runtime/ConsumerGroupMetaSyncProcedure.java | 6 +- .../subscription/CreateSubscriptionProcedure.java | 260 +++++++----------- .../subscription/DropSubscriptionProcedure.java | 147 ++-------- .../subscription/topic/AlterTopicProcedure.java | 44 ++- .../subscription/topic/CreateTopicProcedure.java | 33 ++- .../subscription/topic/DropTopicProcedure.java | 5 +- .../topic/runtime/TopicMetaSyncProcedure.java | 6 +- .../CreateSubscriptionProcedureTest.java | 9 - .../DropSubscriptionProcedureTest.java | 8 - .../protocol/thrift/IoTDBDataNodeReceiver.java | 7 +- .../common/header/ColumnHeaderConstant.java | 21 +- .../common/header/DatasetHeaderFactory.java | 14 +- .../iotdb/db/queryengine/plan/Coordinator.java | 16 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 9 +- .../plan/analyze/ExpressionAnalyzer.java | 13 + .../execution/config/TableConfigTaskVisitor.java | 65 ++++- .../config/executor/ClusterConfigTaskExecutor.java | 42 +++ .../config/executor/IConfigTaskExecutor.java | 12 + .../config/session/ShowCurrentDatabaseTask.java | 79 ++++++ .../config/session/ShowCurrentSqlDialectTask.java | 71 +++++ .../config/session/ShowCurrentTimestampTask.java | 48 ++++ .../config/session/ShowCurrentUserTask.java | 72 +++++ .../execution/config/session/ShowVersionTask.java | 52 ++++ .../memory/StatementMemorySourceVisitor.java | 21 +- .../visitor/ColumnTransformerVisitor.java | 15 +- .../visitor/ExistUnknownTypeInExpression.java | 60 +++++ .../ConcatDeviceAndBindSchemaForHavingVisitor.java | 77 ++++++ .../fetcher/TableDeviceSchemaValidator.java | 62 +++-- .../plan/relational/sql/ast/AstVisitor.java | 28 ++ .../plan/relational/sql/ast/InsertRows.java | 9 +- .../plan/relational/sql/ast/ShowClusterId.java} | 44 ++- .../relational/sql/ast/ShowCurrentDatabase.java} | 44 +-- .../relational/sql/ast/ShowCurrentSqlDialect.java} | 44 +-- .../relational/sql/ast/ShowCurrentTimestamp.java} | 44 +-- .../plan/relational/sql/ast/ShowCurrentUser.java} | 44 ++- .../plan/relational/sql/ast/ShowVariables.java} | 44 ++- .../plan/relational/sql/ast/ShowVersion.java} | 44 ++- .../plan/relational/sql/parser/AstBuilder.java | 45 +++- .../plan/relational/sql/util/SqlFormatter.java | 49 ++++ .../plan/statement/pipe/PipeEnrichedStatement.java | 8 +- .../GeneralRegionAttributeSecurityService.java | 4 +- .../db/schemaengine/table/DataNodeTableCache.java | 10 +- .../db/storageengine/load/LoadTsFileManager.java | 23 +- .../agent/SubscriptionBrokerAgent.java | 78 +++--- .../agent/SubscriptionConsumerAgent.java | 27 +- .../db/subscription/broker/SubscriptionBroker.java | 32 ++- .../broker/SubscriptionPrefetchingQueue.java | 21 +- .../broker/SubscriptionPrefetchingTabletQueue.java | 7 +- .../broker/SubscriptionPrefetchingTsFileQueue.java | 6 +- .../db/subscription/event/SubscriptionEvent.java | 298 +++++---------------- .../event/batch/SubscriptionPipeEventBatch.java | 84 +++++- .../batch/SubscriptionPipeTabletEventBatch.java | 157 ++++------- .../batch/SubscriptionPipeTsFileEventBatch.java | 81 +++--- .../cache/CachedSubscriptionPollResponse.java | 83 ++++++ .../SubscriptionPollResponseCache.java} | 43 +-- .../event/pipe/SubscriptionPipeEmptyEvent.java | 7 - .../event/pipe/SubscriptionPipeEvents.java | 7 - .../pipe/SubscriptionPipeTabletBatchEvents.java | 7 - .../pipe/SubscriptionPipeTsFileBatchEvents.java | 14 +- .../pipe/SubscriptionPipeTsFilePlainEvent.java | 7 - .../SubscriptionEventExtendableResponse.java | 151 +++++++++++ .../SubscriptionEventResponse.java} | 36 ++- .../response/SubscriptionEventSingleResponse.java | 122 +++++++++ .../response/SubscriptionEventTabletResponse.java | 162 +++++++++++ .../response/SubscriptionEventTsFileResponse.java | 170 ++++++++++++ .../receiver/SubscriptionReceiverV1.java | 2 +- .../db/subscription/SubscriptionStatesTest.java | 5 - .../apache/iotdb/commons/conf/CommonConfig.java | 22 ++ .../iotdb/commons/conf/CommonDescriptor.java | 12 + .../subscription/config/SubscriptionConfig.java | 18 +- .../meta/consumer/ConsumerGroupMeta.java | 4 + .../meta/consumer/ConsumerGroupMetaKeeper.java | 25 ++ .../commons/subscription/meta/topic/TopicMeta.java | 19 +- .../apache/iotdb/commons/utils/StatusUtils.java | 1 + .../db/relational/grammar/sql/RelationalSql.g4 | 25 +- 87 files changed, 2644 insertions(+), 1192 deletions(-)
