(iotdb) branch opc-ua updated: reuse

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch opc-ua
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/opc-ua by this push:
     new 6762f937c4f reuse
6762f937c4f is described below

commit 6762f937c4f8088ee5a64fde7726cac80f9f81e3
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Dec 17 15:48:05 2025 +0800

    reuse
---
 .../apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java  | 8 +++-----
 .../org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java   | 2 +-
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
index 160861c1c5e..0e40f880f4f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
@@ -71,13 +71,11 @@ public class OpcUaNameSpace extends 
ManagedNamespaceWithLifecycle {
   public static final String NAMESPACE_URI = "urn:apache:iotdb:opc-server";
   private final SubscriptionModel subscriptionModel;
   private final OpcUaServerBuilder builder;
-  private final String placeHolder;
 
   OpcUaNameSpace(
-      final OpcUaServer server, final OpcUaServerBuilder builder, final String 
placeHolder) {
+      final OpcUaServer server, final OpcUaServerBuilder builder) {
     super(server, NAMESPACE_URI);
     this.builder = builder;
-    this.placeHolder = placeHolder;
 
     subscriptionModel = new SubscriptionModel(server, this);
     getLifecycleManager().addLifecycle(subscriptionModel);
@@ -147,7 +145,7 @@ public class OpcUaNameSpace extends 
ManagedNamespaceWithLifecycle {
         folderSegments[0] = sink.unQualifiedDatabaseName;
 
         for (int j = 0; j < segments.length; ++j) {
-          folderSegments[j + 1] = Objects.isNull(segments[j]) ? placeHolder : 
(String) segments[j];
+          folderSegments[j + 1] = Objects.isNull(segments[j]) ? 
sink.placeHolder : (String) segments[j];
         }
 
         final int finalI = i;
@@ -351,7 +349,7 @@ public class OpcUaNameSpace extends 
ManagedNamespaceWithLifecycle {
         for (final Object segment : tablet.getDeviceID(i).getSegments()) {
           idBuilder
               .append(TsFileConstant.PATH_SEPARATOR)
-              .append(Objects.isNull(segment) ? placeHolder : segment);
+              .append(Objects.isNull(segment) ? sink.placeHolder : segment);
         }
         sourceNameList.add(idBuilder.toString());
       }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
index 035122c6d38..e698130c107 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
@@ -225,7 +225,7 @@ public class OpcUaSink implements PipeConnector {
                                 .setSecurityDir(securityDir)
                                 
.setEnableAnonymousAccess(enableAnonymousAccess);
                         final OpcUaServer newServer = builder.build();
-                        nameSpace = new OpcUaNameSpace(newServer, builder, 
placeHolder);
+                        nameSpace = new OpcUaNameSpace(newServer, builder);
                         nameSpace.startup();
                         newServer.startup().get();
                         return new Pair<>(new AtomicInteger(0), nameSpace);