This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TableModelV1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 32f726d6f8b resolve merge conflicts
new d0067ec94f3 Pipe: Implemented Client-Server model in OPC UA Sink &
Enable anonymous access settings & Corrected date time format (#13100)
new cc6e54f8b21 Pipe: Support converting data type on data sync receiver
metadata mismatch (#13110)
The 2 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:
.../client/IoTDBConfigNodeSyncClientManager.java | 12 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 10 +-
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 | 374 ++++++++
.../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 ++++
.../plan/statement/crud/InsertBaseStatement.java | 8 +-
.../plan/statement/crud/InsertRowStatement.java | 12 +-
.../plan/statement/crud/InsertTabletStatement.java | 10 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../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 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 12 +
pom.xml | 11 +
29 files changed, 2702 insertions(+), 209 deletions(-)
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
