This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes-tmp/table-model-debug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 09f08ccbc7799bac4a068d351dfceefde2f7d9c3 Author: Beyyes <[email protected]> AuthorDate: Mon Jun 3 15:09:58 2024 +0800 merge ty/TableModelGrammar --- .../db/queryengine/plan/planner/plan/node/PlanNodeType.java | 10 ++++++---- .../plan/node/metedata/read/table/TableDeviceFetchNode.java | 5 +++++ .../plan/node/metedata/read/table/TableDeviceScanNode.java | 5 +++++ .../plan/node/metedata/write/DeleteTableDeviceNode.java | 5 +++++ 4 files changed, 21 insertions(+), 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java index dc0c2e87d48..9a374b41bf4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java @@ -224,10 +224,10 @@ public enum PlanNodeType { TIMESERIES_REGION_SCAN((short) 94), REGION_MERGE((short) 95), - CREATE_TABLE_DEVICE((short) 902), - TABLE_DEVICE_SCAN((short) 903), - TABLE_DEVICE_FETCH((short) 904), - DELETE_TABLE_DEVICE((short) 905), + CREATE_TABLE_DEVICE((short) 900), + TABLE_DEVICE_SCAN((short) 901), + TABLE_DEVICE_FETCH((short) 902), + DELETE_TABLE_DEVICE((short) 903), TABLE_SCAN_NODE((short) 1000), TABLE_FILTER_NODE((short) 1001), @@ -481,6 +481,7 @@ public enum PlanNodeType { return TimeseriesRegionScanNode.deserialize(buffer); case 95: return RegionMergeNode.deserialize(buffer); + case 900: return CreateTableDeviceNode.deserialize(buffer); case 901: @@ -489,6 +490,7 @@ public enum PlanNodeType { return TableDeviceFetchNode.deserialize(buffer); case 903: return DeleteTableDeviceNode.deserialize(buffer); + case 1000: return org.apache.iotdb.db.queryengine.plan.relational.planner.node.TableScanNode .deserialize(buffer); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceFetchNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceFetchNode.java index 1a517c95eba..e347a5eb4f2 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceFetchNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceFetchNode.java @@ -84,6 +84,11 @@ public class TableDeviceFetchNode extends SchemaQueryScanNode { return columnHeaderList; } + @Override + public PlanNodeType getType() { + return PlanNodeType.TABLE_DEVICE_FETCH; + } + @Override public void open() throws Exception {} diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceScanNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceScanNode.java index 64400d3dd1e..61e385bfcab 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceScanNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/table/TableDeviceScanNode.java @@ -104,6 +104,11 @@ public class TableDeviceScanNode extends SchemaQueryScanNode { idDeterminedFilterList); } + @Override + public PlanNodeType getType() { + return PlanNodeType.TABLE_DEVICE_SCAN; + } + @Override public void open() throws Exception {} diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/write/DeleteTableDeviceNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/write/DeleteTableDeviceNode.java index 0c54b9bb0a1..fd99a3adfd8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/write/DeleteTableDeviceNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/write/DeleteTableDeviceNode.java @@ -45,6 +45,11 @@ public class DeleteTableDeviceNode extends PlanNode { return table; } + @Override + public PlanNodeType getType() { + return PlanNodeType.DELETE_TABLE_DEVICE; + } + @Override public <R, C> R accept(PlanVisitor<R, C> visitor, C context) { return visitor.visitDeleteTableDevice(this, context);
