(iotdb) branch fix_project_order_in_TableDistributedPlanGenerator updated: perfect ramBytesUsed method

[caogaofei]

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

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


The following commit(s) were added to 
refs/heads/fix_project_order_in_TableDistributedPlanGenerator by this push:
     new 83831fca129 perfect ramBytesUsed method
83831fca129 is described below

commit 83831fca129dad0782da4c66538c9e7bff1ee551
Author: Beyyes <cgf1...@foxmail.com>
AuthorDate: Wed Apr 2 15:54:39 2025 +0800

    perfect ramBytesUsed method
---
 .../operator/source/relational/AbstractAggTableScanOperator.java       | 2 +-
 .../source/relational/AbstractDefaultAggTableScanOperator.java         | 2 +-
 .../relational/planner/distribute/TableDistributedPlanGenerator.java   | 3 +--
 3 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractAggTableScanOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractAggTableScanOperator.java
index 640b38cf698..bd0f9c16ef9 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractAggTableScanOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractAggTableScanOperator.java
@@ -110,7 +110,7 @@ public abstract class AbstractAggTableScanOperator extends 
AbstractDataSourceOpe
 
   private boolean allAggregatorsHasFinalResult = false;
 
-  public AbstractAggTableScanOperator(AbstractAggTableScanOperatorParameter 
parameter) {
+  protected AbstractAggTableScanOperator(AbstractAggTableScanOperatorParameter 
parameter) {
 
     this.sourceId = parameter.sourceId;
     this.operatorContext = parameter.context;
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractDefaultAggTableScanOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractDefaultAggTableScanOperator.java
index f88aa22aabc..ba7e1a226fe 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractDefaultAggTableScanOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractDefaultAggTableScanOperator.java
@@ -36,7 +36,7 @@ public abstract class AbstractDefaultAggTableScanOperator 
extends AbstractAggTab
   private static final long INSTANCE_SIZE =
       
RamUsageEstimator.shallowSizeOfInstance(AbstractDefaultAggTableScanOperator.class);
 
-  public 
AbstractDefaultAggTableScanOperator(AbstractAggTableScanOperatorParameter 
parameter) {
+  protected 
AbstractDefaultAggTableScanOperator(AbstractAggTableScanOperatorParameter 
parameter) {
     super(parameter);
   }
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
index 85142057e4b..5ddaec06dbb 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
@@ -551,7 +551,6 @@ public class TableDistributedPlanGenerator
     }
     Map<Integer, List<TRegionReplicaSet>> cachedSeriesSlotWithRegions = new 
HashMap<>();
 
-    List<PlanNode> result = new ArrayList<>();
     List<DeviceEntry> crossRegionDevices = new ArrayList<>();
 
     final Map<TRegionReplicaSet, DeviceTableScanNode> tableScanNodeMap = new 
HashMap<>();
@@ -596,7 +595,7 @@ public class TableDistributedPlanGenerator
               });
       deviceTableScanNode.appendDeviceEntry(deviceEntry);
     }
-    result.addAll(tableScanNodeMap.values());
+    List<PlanNode> result = new ArrayList<>(tableScanNodeMap.values());
     if (context.hasSortProperty) {
       processSortProperty(node, result, context);
     }