This is an automated email from the ASF dual-hosted git repository.
VGalaxies pushed a change to branch subscription-topic-owner-fencing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 25c34c2bfe8 Subscription: add topic owner epoch fencing
add 0ea029f71a4 Implement alter topic owner entrypoints
No new revisions were added by this update.
Summary of changes:
.../subscription/AbstractSubscriptionSession.java | 82 +++++++++++++++++-----
.../subscription/ISubscriptionTableSession.java | 43 ++++++++++++
.../subscription/ISubscriptionTreeSession.java | 43 ++++++++++++
.../subscription/SubscriptionTableSession.java | 22 ++++++
.../subscription/SubscriptionTreeSession.java | 22 ++++++
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 9 +++
.../apache/iotdb/confignode/manager/IManager.java | 4 ++
.../iotdb/confignode/manager/ProcedureManager.java | 32 +++++++++
.../subscription/SubscriptionCoordinator.java | 21 ++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../subscription/SubscriptionInfoTest.java | 26 +++++++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 ++
.../execution/config/TableConfigTaskVisitor.java | 13 ++++
.../execution/config/TreeConfigTaskVisitor.java | 12 ++++
.../config/executor/ClusterConfigTaskExecutor.java | 30 ++++++++
.../config/executor/IConfigTaskExecutor.java | 3 +
.../{DropTopicTask.java => AlterTopicTask.java} | 23 +++---
.../db/queryengine/plan/parser/ASTVisitor.java | 18 +++++
.../relational/analyzer/StatementAnalyzer.java | 6 ++
.../security/TreeAccessCheckVisitor.java | 7 ++
.../sql/ast/{CreateTopic.java => AlterTopic.java} | 25 ++-----
.../plan/relational/sql/ast/AstVisitor.java | 4 ++
.../plan/relational/sql/parser/AstBuilder.java | 8 +++
.../relational/sql/util/DataNodeSqlFormatter.java | 26 +++++++
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 ++
...picsStatement.java => AlterTopicStatement.java} | 29 ++++----
.../plan/parser/StatementGeneratorTest.java | 15 ++++
.../relational/sql/parser/TopicStatementTest.java} | 36 ++++++----
.../commons/subscription/meta/topic/TopicMeta.java | 11 +++
.../commons/subscription/topic/TopicDeSerTest.java | 23 ++++++
.../db/relational/grammar/sql/RelationalSql.g4 | 5 ++
.../src/main/thrift/confignode.thrift | 4 +-
34 files changed, 551 insertions(+), 76 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/{DropTopicTask.java
=> AlterTopicTask.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateTopic.java
=> AlterTopic.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/{ShowTopicsStatement.java
=> AlterTopicStatement.java} (78%)
copy
iotdb-core/datanode/src/{main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementTablePatternParseVisitor.java
=>
test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/TopicStatementTest.java}
(53%)
