[iotdb] branch master updated: [IOTDB-3379] Add deserialize method for DeviceMergeNode in PlanNodeType (#6151)

[qiaojialin]

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

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 45ca963708 [IOTDB-3379] Add deserialize method for DeviceMergeNode in 
PlanNodeType (#6151)
45ca963708 is described below

commit 45ca963708e346bdbce87efb9748626dbcc30e6c
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Thu Jun 2 18:39:21 2022 +0800

    [IOTDB-3379] Add deserialize method for DeviceMergeNode in PlanNodeType 
(#6151)
---
 .../iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java    | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java
index 20f404fbb2..3b8dbef2c4 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java
@@ -40,6 +40,7 @@ import 
org.apache.iotdb.db.mpp.plan.planner.plan.node.metedata.write.CreateTimeS
 import 
org.apache.iotdb.db.mpp.plan.planner.plan.node.metedata.write.DeleteTimeSeriesNode;
 import 
org.apache.iotdb.db.mpp.plan.planner.plan.node.metedata.write.InvalidateSchemaCacheNode;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.process.AggregationNode;
+import org.apache.iotdb.db.mpp.plan.planner.plan.node.process.DeviceMergeNode;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.process.DeviceViewNode;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.process.ExchangeNode;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.process.FillNode;
@@ -99,7 +100,7 @@ public enum PlanNodeType {
   TIME_SERIES_SCHEMA_SCAN((short) 23),
   SCHEMA_FETCH_SCAN((short) 24),
   SCHEMA_QUERY_MERGE((short) 25),
-  STORAGE_GROUP_SCHEMA_SCAN((short) 26),
+  SCHEMA_QUERY_ORDER_BY_HEAT((short) 26),
   DEVICES_COUNT((short) 27),
   TIME_SERIES_COUNT((short) 28),
   LEVEL_TIME_SERIES_COUNT((short) 29),
@@ -122,8 +123,7 @@ public enum PlanNodeType {
   LAST_QUERY_SCAN((short) 46),
   ALIGNED_LAST_QUERY_SCAN((short) 47),
   LAST_QUERY_MERGE((short) 48),
-  NODE_PATHS_COUNT((short) 49),
-  SCHEMA_QUERY_ORDER_BY_HEAT((short) 50);
+  NODE_PATHS_COUNT((short) 49);
 
   private final short nodeType;
 
@@ -203,6 +203,8 @@ public enum PlanNodeType {
         return SchemaFetchScanNode.deserialize(buffer);
       case 25:
         return SchemaQueryMergeNode.deserialize(buffer);
+      case 26:
+        return SchemaQueryOrderByHeatNode.deserialize(buffer);
       case 27:
         return DevicesCountNode.deserialize(buffer);
       case 28:
@@ -219,6 +221,8 @@ public enum PlanNodeType {
         return AlignedSeriesScanNode.deserialize(buffer);
       case 34:
         return AlignedSeriesAggregationScanNode.deserialize(buffer);
+      case 35:
+        return DeviceMergeNode.deserialize(buffer);
       case 36:
         return SchemaFetchMergeNode.deserialize(buffer);
       case 37:
@@ -247,8 +251,6 @@ public enum PlanNodeType {
         return LastQueryMergeNode.deserialize(buffer);
       case 49:
         return NodePathsCountNode.deserialize(buffer);
-      case 50:
-        return SchemaQueryOrderByHeatNode.deserialize(buffer);
       default:
         throw new IllegalArgumentException("Invalid node type: " + nodeType);
     }