You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2024/07/12 09:56:03 UTC
(iotdb) 01/01: temp
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/explain
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8b73b67fdaac815fc726d68aede98d1f126d1042
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Fri Jul 12 17:55:42 2024 +0800
temp
---
.../scheduler/FragmentInstanceDispatcherImpl.java | 8 ++---
.../FragmentInstanceStatisticsDrawer.java | 40 +++++++++++-----------
2 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
index 2b0738ea59f..bb83aca6a14 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java
@@ -124,8 +124,8 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
// unsafe for current FragmentInstance scheduler framework. We need to implement the
// topological dispatch according to dependency relations between FragmentInstances
private Future<FragInstanceDispatchResult> dispatchRead(List<FragmentInstance> instances) {
+ long startTime = System.nanoTime();
for (FragmentInstance instance : instances) {
- long startTime = System.nanoTime();
try (SetThreadName threadName = new SetThreadName(instance.getId().getFullId())) {
dispatchOneInstance(instance);
} catch (FragmentInstanceDispatchException e) {
@@ -146,11 +146,11 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
// TypeProvider is not used in EXPLAIN ANALYZE, so we can clear it
instance.getFragment().clearTypeProvider();
}
- long dispatchReadTime = System.nanoTime() - startTime;
- QUERY_EXECUTION_METRIC_SET.recordExecutionCost(DISPATCH_READ, dispatchReadTime);
- queryContext.recordDispatchCost(dispatchReadTime);
}
}
+ long dispatchReadTime = System.nanoTime() - startTime;
+ QUERY_EXECUTION_METRIC_SET.recordExecutionCost(DISPATCH_READ, dispatchReadTime);
+ queryContext.recordDispatchCost(dispatchReadTime);
return immediateFuture(new FragInstanceDispatchResult(true));
}
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsDrawer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsDrawer.java
index d971c3a8f15..4db9679377b 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsDrawer.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/statistics/FragmentInstanceStatisticsDrawer.java
@@ -245,6 +245,26 @@ public class FragmentInstanceStatisticsDrawer {
2,
"loadTimeSeriesMetadataAlignedMemUnSeqTime",
queryStatistics.loadTimeSeriesMetadataAlignedMemUnSeqTime * NS_TO_MS_FACTOR);
+ addLineWithValueCheck(
+ singleFragmentInstanceArea,
+ 2,
+ "alignedTimeSeriesMetadataModificationCount",
+ queryStatistics.getAlignedTimeSeriesMetadataModificationCount());
+ addLineWithValueCheck(
+ singleFragmentInstanceArea,
+ 2,
+ "alignedTimeSeriesMetadataModificationTime",
+ queryStatistics.getAlignedTimeSeriesMetadataModificationTime() * NS_TO_MS_FACTOR);
+ addLineWithValueCheck(
+ singleFragmentInstanceArea,
+ 2,
+ "nonAlignedTimeSeriesMetadataModificationCount",
+ queryStatistics.getNonAlignedTimeSeriesMetadataModificationCount());
+ addLineWithValueCheck(
+ singleFragmentInstanceArea,
+ 2,
+ "nonAlignedTimeSeriesMetadataModificationTime",
+ queryStatistics.getNonAlignedTimeSeriesMetadataModificationTime() * NS_TO_MS_FACTOR);
addLineWithValueCheck(
singleFragmentInstanceArea,
@@ -333,26 +353,6 @@ public class FragmentInstanceStatisticsDrawer {
2,
"pageReaderMaxUsedMemorySize",
queryStatistics.pageReaderMaxUsedMemorySize);
- addLineWithValueCheck(
- singleFragmentInstanceArea,
- 1,
- "AlignedTimeSeriesMetadataModificationCount",
- queryStatistics.getAlignedTimeSeriesMetadataModificationCount());
- addLineWithValueCheck(
- singleFragmentInstanceArea,
- 1,
- "AlignedTimeSeriesMetadataModificationTime",
- queryStatistics.getAlignedTimeSeriesMetadataModificationTime() * NS_TO_MS_FACTOR);
- addLineWithValueCheck(
- singleFragmentInstanceArea,
- 1,
- "NonAlignedTimeSeriesMetadataModificationCount",
- queryStatistics.getNonAlignedTimeSeriesMetadataModificationCount());
- addLineWithValueCheck(
- singleFragmentInstanceArea,
- 1,
- "NonAlignedTimeSeriesMetadataModificationTime",
- queryStatistics.getNonAlignedTimeSeriesMetadataModificationTime() * NS_TO_MS_FACTOR);
}
private void addLine(List<StatisticLine> resultForSingleInstance, int level, String value) {