This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2c10213db2f Improve robustness of removing peer step of region
migration (#13078)
new e0129ac0741 Pipe: Fix the class not found exception of OPC UA
connector (#13086)
new 1b650f5405f Subscription: avoid incomplete resource release of
prefetching queue caused by restarting subscription pipe (#13079)
new 81f3a332b70 Update out-dated profile name in readmes (#13092)
new c59b2e7f4b7 Convert date to LocalDate in sortlist()
new 81e8c3ac397 Subscription: java client supports Create Topic If Not
Exists and Drop Topic If Exists (#13081)
new 91b7b6561ab PipePlugin/Subscription: The Drop PipePlugin operation
adds a check to see if there is a Topic that uses PipePlugin as a processor
(#13048)
new 8648df01ce5 Update multi-language-client CI with path rule (#13095)
new 3a7a1c3db3e Fix IoTConsensus log explosion when stoping one node #13101
new fce6df13bfa Unify string type inference (#13094)
new daa834140e5 Enhance transferLeader retry frequency when migrating
region #13098
new 50b7371c3f7 Add wal compression metric items (#13105)
new 18df70d0fb9 Remove the usage of lt_downsampling_java8 (#13108)
new a75f72ed875 Fix RegionGroup concurreny problem (#13103)
new 539d707add3 Handle exception when the WAL initializtion is interrupted
(#13102)
new 23a83d99c72 Report INTERNAL_SERVER_ERROR in executeBatch (#13106)
new 6ffd18845d9 Fixed the rest service When executing unsupported SQL,
return null
new 83d2b42f7ad Update license information (#13113)
new 21e0a079945 Pipe: Implemented Client-Server model in OPC UA Sink &
Enable anonymous access settings & Corrected date time format (#13100)
new f45a1b21f9d Pipe: Support converting data type on data sync receiver
metadata mismatch (#13110)
The 19 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/multi-language-client.yml | 28 +-
LICENSE | 59 +-
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 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 12 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 10 +-
.../persistence/partition/RegionGroup.java | 28 +-
.../persistence/subscription/SubscriptionInfo.java | 31 +
.../procedure/env/RegionMaintainHandler.java | 10 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +
.../consensus/iot/IoTConsensusServerImpl.java | 1 +
iotdb-core/datanode/pom.xml | 4 +
.../client/IoTDBDataNodeAsyncClientManager.java | 12 +-
.../client/IoTDBDataNodeSyncClientManager.java | 12 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../connector/protocol/opcua/OpcUaConnector.java | 207 ++---
.../connector/protocol/opcua/OpcUaNameSpace.java | 373 ++++++++
.../protocol/opcua/OpcUaServerBuilder.java | 32 +-
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 11 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 40 +-
.../transform/converter/ArrayConverter.java | 940 +++++++++++++++++++++
.../transform/converter/ValueConverter.java | 787 +++++++++++++++++
.../statement/PipeConvertedInsertRowStatement.java | 112 +++
.../PipeConvertedInsertTabletStatement.java | 64 ++
...peStatementDataTypeConvertExecutionVisitor.java | 173 ++++
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 18 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 18 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../planner/plan/node/write/InsertTabletNode.java | 1 +
.../plan/statement/crud/InsertBaseStatement.java | 8 +-
.../plan/statement/crud/InsertRowStatement.java | 12 +-
.../plan/statement/crud/InsertTabletStatement.java | 10 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 88 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +
.../dataregion/memtable/TsFileProcessor.java | 10 +-
.../wal/allocation/FirstCreateStrategy.java | 7 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 7 +
.../dataregion/wal/io/WALInputStream.java | 36 +-
.../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 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 4 +-
.../node/write/InsertTabletNodeSerdeTest.java | 35 +
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 6 +-
.../config/constant/PipeConnectorConstant.java | 20 +
.../connector/client/IoTDBSyncClientManager.java | 10 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 15 +
.../connector/protocol/IoTDBSslSyncConnector.java | 11 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 19 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 12 +
library-udf/pom.xml | 7 -
.../apache/iotdb/library/dprofile/UDTFSample.java | 24 +-
.../apache/iotdb/library/dprofile/util/Area.java | 62 ++
.../apache/iotdb/library/dprofile/util/Bucket.java | 85 ++
.../library/dprofile/util/LTThreeBuckets.java | 57 ++
.../library/dprofile/util/OnePassBucketizer.java | 68 ++
.../library/dprofile/util/SlidingCollector.java | 111 +++
.../iotdb/library/dprofile/util/Triangle.java | 59 ++
pom.xml | 68 +-
71 files changed, 3981 insertions(+), 478 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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaNameSpace.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ArrayConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertRowStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Area.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Bucket.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/LTThreeBuckets.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/OnePassBucketizer.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/SlidingCollector.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Triangle.java
