This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch DeviceMergeDe in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3ab9b4a0a38c98b84c1e4c1557f6617d2249cb3c Author: JackieTien97 <[email protected]> AuthorDate: Thu Jun 2 15:29:01 2022 +0800 Add deserialize method for DeviceMergeNode in PlanNodeType --- .../org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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..5a0a53ba92 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,6 @@ 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), DEVICES_COUNT((short) 27), TIME_SERIES_COUNT((short) 28), LEVEL_TIME_SERIES_COUNT((short) 29), @@ -219,6 +219,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:
