This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f1a224e56c1 Subscription: unify tablet push consumer builder return
type (#14971)
add ede623a27d8 Pipe: Implemented OPC DA Sink for local COM & Fixed the
newest value of OPC UA Sink (#14964)
No new revisions were added by this update.
Summary of changes:
dependencies.json | 1 +
iotdb-core/datanode/pom.xml | 8 +
.../PipeDataRegionConnectorConstructor.java | 4 +
.../connector/protocol/opcda/OpcDaConnector.java | 138 ++++++++
.../pipe/connector/protocol/opcda/OpcDaHeader.java | 200 +++++++++++
.../protocol/opcda/OpcDaServerHandle.java | 390 +++++++++++++++++++++
.../connector/protocol/opcua/OpcUaConnector.java | 50 ++-
.../connector/protocol/opcua/OpcUaNameSpace.java | 2 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 5 +
.../OpcDaConnector.java} | 8 +-
.../config/constant/PipeConnectorConstant.java | 6 +
pom.xml | 5 +
12 files changed, 797 insertions(+), 20 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaHeader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/{opcua/OpcUaConnector.java
=> opcda/OpcDaConnector.java} (88%)
