This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch enable-time-other-name
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fdd5fe2c3d6 clean
add b4a3e2e52b2 fix: reserve memory for sorting indices during query
execution (#16960)
add 9d9902fa685 Fix insert object segment error when use multiple dirs
(#16965)
add ad0416e00c7 Disabled the repeatable pipe log when the receiver is down
(#16963)
add 82f2dc4c320 Fixed the configMTree deserialisation bug for "root"
database (#16961)
add b75bcc62f9b Pipe: Fixed the bug that batch memory is not visible to
pipe memory management (#16962)
add cb18a95fc01 Pipe: Implemented OPC Sink for outer server & Set
configuration and changed the default value of the server security policies &
Made the default quality configurable and does not throw when non-value/quality
measurement is encountered (#16944)
add e6502ee72ce Merge branch 'master' of https://github.com/apache/iotdb
into enable-time-other-name
No new revisions were added by this update.
Summary of changes:
integration-test/pom.xml | 1 -
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 190 +++++++++++--
.../confignode/persistence/schema/ConfigMTree.java | 4 +-
.../persistence/schema/ConfigMTreeTest.java | 2 +-
iotdb-core/datanode/pom.xml | 12 +
.../evolvable/batch/PipeTabletEventBatch.java | 6 +
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 305 ++++++++++++++++++---
.../sink/protocol/opcua/client/ClientRunner.java | 112 ++++++++
.../opcua/client}/IoTDBKeyStoreLoaderClient.java | 35 +--
.../protocol/opcua/client/IoTDBOpcUaClient.java | 301 ++++++++++++++++++++
.../opcua/{ => server}/OpcUaKeyStoreLoader.java | 2 +-
.../opcua/{ => server}/OpcUaNameSpace.java | 83 ++++--
.../opcua/{ => server}/OpcUaServerBuilder.java | 97 ++++---
.../fragment/FragmentInstanceContext.java | 11 +-
.../schemaregion/utils/ResourceByPathUtils.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 18 +-
.../memtable/AbstractWritableMemChunk.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 37 ++-
.../dataregion/memtable/ReadOnlyMemChunk.java | 29 ++
.../db/utils/datastructure/AlignedTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 21 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 3 +-
.../fragment/FragmentInstanceExecutionTest.java | 97 +++++++
.../iotdb/commons/client/ClientPoolFactory.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 13 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../pipe/config/constant/PipeSinkConstant.java | 37 ++-
pom.xml | 10 +
29 files changed, 1264 insertions(+), 180 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/ClientRunner.java
copy {example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client}/IoTDBKeyStoreLoaderClient.java
(78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaKeyStoreLoader.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaNameSpace.java (87%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/{
=> server}/OpcUaServerBuilder.java (82%)
