This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch unify_string_infer
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e46f68bfef6 Unify string type inference
add d8a200516c1 Pipe: Fix the class not found exception of OPC UA
connector (#13086)
add 83f8db0a8b3 Subscription: avoid incomplete resource release of
prefetching queue caused by restarting subscription pipe (#13079)
add b1bc66671bd Update out-dated profile name in readmes (#13092)
add 0733a499a0f Convert date to LocalDate in sortlist()
add 86ddd749cc0 Subscription: java client supports Create Topic If Not
Exists and Drop Topic If Exists (#13081)
add 97f9ef52942 PipePlugin/Subscription: The Drop PipePlugin operation
adds a check to see if there is a Topic that uses PipePlugin as a processor
(#13048)
add 5971fe17754 Merge branch 'master' of github.com:apache/iotdb into
unify_string_infer
add b9205a08857 rm useless submodule
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
README_ZH.md | 2 +-
...eSingleEnvDemoIT.java => IoTDBPipeOPCUAIT.java} | 17 +-
.../it/local/IoTDBSubscriptionTopicIT.java | 178 +++++++++++++++++++++
.../java/org/apache/iotdb/session/Session.java | 9 +-
.../session/subscription/SubscriptionSession.java | 94 ++++++++++-
.../java/org/apache/iotdb/session/TabletTest.java | 75 ++++++++-
.../persistence/subscription/SubscriptionInfo.java | 31 ++++
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +
.../planner/plan/node/write/InsertTabletNode.java | 1 +
.../agent/SubscriptionBrokerAgent.java | 15 +-
.../agent/SubscriptionConsumerAgent.java | 4 +-
.../db/subscription/broker/SubscriptionBroker.java | 102 ++++++++----
.../broker/SubscriptionPrefetchingQueue.java | 69 +++-----
.../broker/SubscriptionPrefetchingTabletQueue.java | 6 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 24 ++-
.../SubscriptionConnectorSubtaskLifeCycle.java | 2 +-
.../node/write/InsertTabletNodeSerdeTest.java | 35 ++++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 19 ++-
pom.xml | 2 +-
20 files changed, 579 insertions(+), 116 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/{IoTDBPipeSingleEnvDemoIT.java
=> IoTDBPipeOPCUAIT.java} (74%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicIT.java
