This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 632d87e2dbc Subscription: fully managed tsfile parsing process for
tsfile format topic (#15524)
add 7f54522b479 Subscription: support drop subscription from session &
intro allTopicMessagesHaveBeenConsumed for pull consumer (#15486)
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/SubscriptionSessionExample.java | 4 +-
.../dual/treemodel/IoTDBSubscriptionTopicIT.java | 2 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 97 ++++++++++++++++++++++
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 2 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
.../subscription/AbstractSubscriptionSession.java | 19 ++++-
.../subscription/ISubscriptionTableSession.java | 22 +++++
.../subscription/ISubscriptionTreeSession.java | 22 +++++
.../subscription/SubscriptionTableSession.java | 12 +++
.../subscription/SubscriptionTreeSession.java | 12 +++
.../consumer/ISubscriptionTablePullConsumer.java | 12 +++
.../consumer/ISubscriptionTreePullConsumer.java | 12 +++
.../base/AbstractSubscriptionConsumer.java | 5 ++
.../table/SubscriptionTablePullConsumer.java | 5 ++
.../tree/SubscriptionTreePullConsumer.java | 5 ++
.../session/subscription/model/Subscription.java | 15 +++-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 5 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../subscription/SubscriptionTableResp.java | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 9 ++
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../subscription/SubscriptionCoordinator.java | 27 ++++++
.../persistence/subscription/SubscriptionInfo.java | 59 ++++++++++---
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 ++
.../execution/config/TableConfigTaskVisitor.java | 9 ++
.../execution/config/TreeConfigTaskVisitor.java | 8 ++
.../config/executor/ClusterConfigTaskExecutor.java | 25 ++++++
.../config/executor/IConfigTaskExecutor.java | 4 +
...ropTopicTask.java => DropSubscriptionTask.java} | 24 +++---
.../sys/subscription/ShowSubscriptionsTask.java | 13 ++-
.../db/queryengine/plan/parser/ASTVisitor.java | 17 ++++
.../relational/analyzer/StatementAnalyzer.java | 6 ++
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../ast/{DropTopic.java => DropSubscription.java} | 22 ++---
.../plan/relational/sql/parser/AstBuilder.java | 9 ++
.../plan/relational/sql/util/SqlFormatter.java | 34 +++++---
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 ++
...atement.java => DropSubscriptionStatement.java} | 24 +++---
iotdb-core/node-commons/pom.xml | 4 +
.../schema/column/ColumnHeaderConstant.java | 2 +
.../meta/consumer/ConsumerGroupMeta.java | 96 ++++++++++++++++++---
.../meta/consumer/ConsumerGroupMetaKeeper.java | 7 ++
.../meta/subscription/SubscriptionMeta.java | 76 +++--------------
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
.../src/main/thrift/confignode.thrift | 12 ++-
50 files changed, 643 insertions(+), 147 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/{DropTopicTask.java
=> DropSubscriptionTask.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropTopic.java
=> DropSubscription.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/{DropTopicStatement.java
=> DropSubscriptionStatement.java} (79%)
