(iotdb) branch reduce-node-path-log updated: Finish

[yongzao]

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

yongzao pushed a commit to branch reduce-node-path-log
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/reduce-node-path-log by this 
push:
     new ed3201ed0bf Finish
ed3201ed0bf is described below

commit ed3201ed0bfa9533b2d39e420b889ab3134d92bf
Author: YongzaoDan <532741...@qq.com>
AuthorDate: Mon Jan 15 11:18:34 2024 +0800

    Finish
---
 .../iotdb/confignode/manager/ConfigManager.java    | 73 +++++++++++++++++++---
 1 file changed, 66 insertions(+), 7 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index 69c8729e847..ba369659ed4 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -26,6 +26,7 @@ import org.apache.iotdb.common.rpc.thrift.TDataNodeLocation;
 import org.apache.iotdb.common.rpc.thrift.TFlushReq;
 import org.apache.iotdb.common.rpc.thrift.TRegionReplicaSet;
 import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.common.rpc.thrift.TSchemaNode;
 import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
 import org.apache.iotdb.common.rpc.thrift.TSetSpaceQuotaReq;
 import org.apache.iotdb.common.rpc.thrift.TSetThrottleQuotaReq;
@@ -776,19 +777,77 @@ public class ConfigManager implements IManager {
       TSchemaNodeManagementResp result =
           resp.convertToRpcSchemaNodeManagementPartitionResp(
               getLoadManager().getRegionPriorityMap());
-
-      LOGGER.info(
-          "getNodePathsPartition receive devicePaths: {}, level: {}, return 
TSchemaNodeManagementResp: {}",
-          partialPath,
-          level,
-          result);
-
+      printNodePathsPartition(partialPath, scope, level, result);
       return result;
     } else {
       return new TSchemaNodeManagementResp().setStatus(status);
     }
   }
 
+  private void printNodePathsPartition(
+      PartialPath partialPath,
+      PathPatternTree scope,
+      Integer level,
+      TSchemaNodeManagementResp resp) {
+    final String lineSeparator = System.lineSeparator();
+
+    StringBuilder devicePathString = new StringBuilder("{");
+    for (String devicePath : scope.getAllDevicePatterns()) {
+      
devicePathString.append(lineSeparator).append("\t").append(devicePath).append(",");
+    }
+    devicePathString.append(lineSeparator).append("}");
+
+    StringBuilder schemaNodeManagementRespString = new StringBuilder("{");
+    schemaNodeManagementRespString
+        .append(lineSeparator)
+        .append("\tTSStatus=")
+        .append(resp.getStatus().getCode())
+        .append(",");
+    Map<String, Map<TSeriesPartitionSlot, TRegionReplicaSet>> schemaRegionMap =
+        resp.getSchemaRegionMap();
+    for (Map.Entry<String, Map<TSeriesPartitionSlot, TRegionReplicaSet>> 
databaseEntry :
+        schemaRegionMap.entrySet()) {
+      String database = databaseEntry.getKey();
+      schemaNodeManagementRespString
+          .append(lineSeparator)
+          .append(DATABASE)
+          .append(database)
+          .append(": {");
+      for (Map.Entry<TSeriesPartitionSlot, TRegionReplicaSet> regionEntry :
+          databaseEntry.getValue().entrySet()) {
+        schemaNodeManagementRespString
+            .append(lineSeparator)
+            .append("\t\tSeriesSlot: ")
+            .append(regionEntry.getKey())
+            .append(", RegionGroup: {")
+            .append("id: ")
+            .append(regionEntry.getValue().getRegionId().getId())
+            .append(", DataNodes: ")
+            .append(
+                regionEntry.getValue().getDataNodeLocations().stream()
+                    .map(TDataNodeLocation::getDataNodeId)
+                    .collect(Collectors.toList()))
+            .append("}");
+      }
+      schemaNodeManagementRespString.append(lineSeparator).append("\t},");
+    }
+
+    schemaNodeManagementRespString.append("matchedNode: {");
+    for (TSchemaNode matchedNode : resp.getMatchedNode()) {
+      
schemaNodeManagementRespString.append(lineSeparator).append("\t\t").append(matchedNode);
+    }
+    schemaNodeManagementRespString.append(lineSeparator).append("\t}");
+
+    schemaNodeManagementRespString.append(lineSeparator).append("}");
+    LOGGER.info(
+        "[GetNodePathsPartition]: {} Received PartialPath: {}, Level: {}, 
PathPatternTree: {}, Resp: {}",
+        lineSeparator,
+        partialPath,
+        level,
+        devicePathString,
+        schemaNodeManagementRespString);
+  }
+
   @Override
   public TDataPartitionTableResp getDataPartition(GetDataPartitionPlan 
getDataPartitionPlan) {
     // Construct empty response