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:02 UTC
(iotdb) branch beyyes/explain created (now 8b73b67fdaa)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/explain
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 8b73b67fdaa temp
This branch includes the following new commits:
new 8b73b67fdaa temp
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: temp
Posted by ca...@apache.org.
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) {