Skip to content

Commit 581fffb

Browse files
authored
Add cached device number info for last query
1 parent ceae5b6 commit 581fffb

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.LastByDescAccumulator;
2727
import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.LastDescAccumulator;
2828
import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.TableAggregator;
29+
import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanGraphPrinter;
2930
import org.apache.iotdb.db.queryengine.plan.relational.metadata.ColumnSchema;
3031
import org.apache.iotdb.db.queryengine.plan.relational.metadata.DeviceEntry;
3132
import org.apache.iotdb.db.queryengine.plan.relational.metadata.QualifiedObjectName;
@@ -96,6 +97,8 @@ public LastQueryAggTableScanOperator(
9697
this.hitCachedResults = hitCachedResults;
9798
this.dbName = qualifiedObjectName.getDatabaseName();
9899

100+
this.operatorContext.recordSpecifiedInfo(
101+
PlanGraphPrinter.CACHED_DEVICE_NUMBER, Integer.toString(cachedDeviceEntries.size()));
99102
for (int i = 0; i < parameter.tableAggregators.size(); i++) {
100103
if (parameter.tableAggregators.get(i).getAccumulator() instanceof LastAccumulator) {
101104
lastTimeAggregationIdx = i;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter
119119

120120
private static final String REGION_NOT_ASSIGNED = "Not Assigned";
121121
public static final String DEVICE_NUMBER = "DeviceNumber";
122+
public static final String CACHED_DEVICE_NUMBER = "CachedDeviceNumber";
122123
public static final String CURRENT_USED_MEMORY = "CurrentUsedMemory";
123124
public static final String MAX_USED_MEMORY = "MaxUsedMemory";
124125
public static final String MAX_RESERVED_MEMORY = "MaxReservedMemory";

0 commit comments

Comments
 (0)