This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch rc/2.0.4
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7f574ba4196 Fixed the bug that update / delete devices with no effect
may end up changing all the devices
new 8d5e92dbd67 Subscription IT: add IoTDBSubscriptionTopicIT for table
model (#15525)
new 6de423bd05b Subscription: fully managed tsfile parsing process for
tsfile format topic (#15524)
new 9763fdb2426 Subscription: support drop subscription from session &
intro allTopicMessagesHaveBeenConsumed for pull consumer (#15486)
new 0c23210049e Fix TVF return unexpected result when passing ORIGIN
argument
new b564aa47802 Modify the exception and message of wrong
'setConfiguration' Statement in table model (#15541)
new 64ec540244c Subscription: decrease reference count for managed parsed
tsfile event (#15555)
new f47f8a8f1e0 Fixed the bug that the first query may be rejected when
read only in table model for simple consensus
new 85b7ac203c3 Change Error Code from 301 to 719 in case of sort memory
not enough
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/pipe-it.yml | 90 ++++-
.../apache/iotdb/SubscriptionSessionExample.java | 4 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 57 ++-
.../iotdb/subscription/it/dual/tablemodel/.gitkeep | 18 -
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 407 +++++++++++++++++++++
.../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 +
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +
.../iotdb/consensus/simple/SimpleConsensus.java | 3 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../task/builder/PipeDataNodeTaskBuilder.java | 11 +-
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../execution/executor/RegionWriteExecutor.java | 2 +
.../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 | 15 +-
.../plan/relational/sql/util/SqlFormatter.java | 34 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
...atement.java => DropSubscriptionStatement.java} | 24 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 6 +
.../batch/SubscriptionPipeTsFileEventBatch.java | 30 +-
.../iotdb/db/utils/sort/SortBufferManager.java | 4 +-
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 +---
.../relational/tvf/CumulateTableFunction.java | 20 +-
.../builtin/relational/tvf/HOPTableFunction.java | 18 +-
.../relational/tvf/SessionTableFunction.java | 1 +
.../relational/tvf/TumbleTableFunction.java | 14 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
.../src/main/thrift/confignode.thrift | 12 +-
66 files changed, 1270 insertions(+), 211 deletions(-)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/.gitkeep
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/IoTDBSubscriptionTopicIT.java
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%)
