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 <[email protected]> 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) {
