You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/04/14 02:12:23 UTC

[iotdb] 01/03: modify print

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

hui pushed a commit to branch lmh/groupByTest
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 8d22dc2ac13eece97a3bdf86b58384276e8f3dd2
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Fri Apr 14 10:06:43 2023 +0800

    modify print
---
 .../iotdb/db/mpp/statistics/QueryStatistics.java   | 107 +++++++++++----------
 1 file changed, 54 insertions(+), 53 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java b/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
index e388f02abe..ef615393d4 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/statistics/QueryStatistics.java
@@ -304,122 +304,123 @@ public class QueryStatistics {
           .append("|   |___AggScanOperator ")
           .append(operationStatistics.get(AGG_SCAN_OPERATOR))
           .append(System.lineSeparator());
+
+      builder.append("|   |    |[FileLoaderInterface]").append(System.lineSeparator());
       builder
-          .append("|   |   |___CalcNextAggRes ")
-          .append(operationStatistics.get(CAL_NEXT_AGG_RES))
+          .append("|   |       |___loadTSMetadata ")
+          .append(operationStatistics.get(LOAD_TIME_SERIES_METADATA_ALIGNED))
           .append(System.lineSeparator());
       builder
-          .append("|   |   |___AggFromStat ")
-          .append(operationStatistics.get(CAL_AGG_FROM_STAT))
+          .append("|   |       |___loadChunkMetaList ")
+          .append(operationStatistics.get(LOAD_CHUNK_METADATA_LIST))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___loadTSMeta ")
-          .append(operationStatistics.get(LOAD_TIME_SERIES_METADATA_ALIGNED))
+          .append("|   |       |___loadPageReaderList ")
+          .append(operationStatistics.get(LOAD_PAGE_READER_LIST))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___AggFromFile ")
-          .append(operationStatistics.get(CAL_AGG_FROM_FILE))
+          .append("|   |       |___pageReader ")
+          .append(operationStatistics.get(PAGE_READER))
           .append(System.lineSeparator());
+
+      builder.append("|   |    |[AggregatorInterface]").append(System.lineSeparator());
       builder
-          .append("|   |       |   |___AggFromFileStat ")
-          .append(operationStatistics.get(CAL_AGG_FROM_FILE_STAT))
+          .append("|   |       |___AggFromStat ")
+          .append(operationStatistics.get(CAL_AGG_FROM_STAT))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |   |___loadChunkMeta ")
-          .append(operationStatistics.get(LOAD_CHUNK_METADATA_LIST))
+          .append("|   |       |___AggFromRawData ")
+          .append(operationStatistics.get(CAL_AGG_FROM_RAW_DATA))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |   |___AggFromChunk ")
-          .append(operationStatistics.get(CAL_AGG_FROM_CHUNK))
+          .append("|   |       |   |___AggProcTsBlock ")
+          .append(operationStatistics.get(AGGREGATOR_PROCESS_TSBLOCK))
           .append(System.lineSeparator());
+
+      builder.append("|   |    |[OperatorMethods]").append(System.lineSeparator());
       builder
-          .append("|   |       |       |___AggFromChunkStat ")
-          .append(operationStatistics.get(CAL_AGG_FROM_CHUNK_STAT))
+          .append("|   |       |___CalcNextAggRes ")
+          .append(operationStatistics.get(CAL_NEXT_AGG_RES))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |       |___loadChunk ")
-          .append(operationStatistics.get(LOAD_PAGE_READER_LIST))
+          .append("|   |       |___AggFromFile ")
+          .append(operationStatistics.get(CAL_AGG_FROM_FILE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |       |___AggFromPage ")
-          .append(operationStatistics.get(CAL_AGG_FROM_PAGE))
+          .append("|   |       |   |___TryAggFromFileStat ")
+          .append(operationStatistics.get(CAL_AGG_FROM_FILE_STAT))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |           |___AggFromPageStat ")
-          .append(operationStatistics.get(CAL_AGG_FROM_PAGE_STAT))
+          .append("|   |       |___AggFromChunk ")
+          .append(operationStatistics.get(CAL_AGG_FROM_CHUNK))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |           |___loadPage ")
-          .append(operationStatistics.get(PAGE_READER))
+          .append("|   |       |   |___TryAggFromChunkStat ")
+          .append(operationStatistics.get(CAL_AGG_FROM_CHUNK_STAT))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |           |___AggFromRawData ")
-          .append(operationStatistics.get(CAL_AGG_FROM_RAW_DATA))
+          .append("|   |       |___AggFromPage ")
+          .append(operationStatistics.get(CAL_AGG_FROM_PAGE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |               |___AggProcTsBlock ")
-          .append(operationStatistics.get(AGGREGATOR_PROCESS_TSBLOCK))
+          .append("|   |       |   |___TryAggFromPageStat ")
+          .append(operationStatistics.get(CAL_AGG_FROM_PAGE_STAT))
           .append(System.lineSeparator());
       builder
           .append("|   |       |___BuildAggRes ")
           .append(operationStatistics.get(BUILD_AGG_RES))
           .append(System.lineSeparator());
+
+      builder.append("|   |    |[SeriesScanUtilCost]").append(System.lineSeparator());
       builder
           .append("|   |       |___hasNextFile ")
           .append(operationStatistics.get(HAS_NEXT_FILE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___hasNextChunk ")
-          .append(operationStatistics.get(HAS_NEXT_CHUNK))
-          .append(System.lineSeparator());
-      builder
-          .append("|   |       |___hasNextPage ")
-          .append(operationStatistics.get(HAS_NEXT_PAGE))
+          .append("|   |       |   |___findEndTime ")
+          .append(operationStatistics.get(FIND_END_TIME))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___hasNextOverlappedPage ")
-          .append(operationStatistics.get(HAS_NEXT_OVERLAPPED_PAGE))
+          .append("|   |       |   |___pickFirstTimeSeriesMetadata ")
+          .append(operationStatistics.get(PICK_FIRST_TIMESERIES_METADATA))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___filterFirstTimeSeriesMetadata ")
+          .append("|   |       |   |___filterFirstTimeSeriesMetadata ")
           .append(operationStatistics.get(FILTER_FIRST_TIMESERIES_METADATA))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___filterFirstChunkMetadata ")
-          .append(operationStatistics.get(FILTER_FIRST_CHUNK_METADATA))
-          .append(System.lineSeparator());
-      builder
-          .append("|   |       |___findEndTime ")
-          .append(operationStatistics.get(FIND_END_TIME))
+          .append("|   |       |___hasNextChunk ")
+          .append(operationStatistics.get(HAS_NEXT_CHUNK))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___pickFirstTimeSeriesMetadata ")
-          .append(operationStatistics.get(PICK_FIRST_TIMESERIES_METADATA))
+          .append("|   |       |   |___filterFirstChunkMetadata ")
+          .append(operationStatistics.get(FILTER_FIRST_CHUNK_METADATA))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___initFirstPage ")
-          .append(operationStatistics.get(INIT_FIRST_PAGE))
+          .append("|   |       |___hasNextPage ")
+          .append(operationStatistics.get(HAS_NEXT_PAGE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___mergeReader#addReader ")
-          .append(operationStatistics.get(MERGE_READER_ADD_READER))
+          .append("|   |       |___hasNextOverlappedPage ")
+          .append(operationStatistics.get(HAS_NEXT_OVERLAPPED_PAGE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___mergeReader#nextTimeValuePair ")
+          .append("|   |       |   |___mergeReader#nextTimeValuePair ")
           .append(operationStatistics.get(MERGE_READER_NEXT))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___mergeReader#updateHeap ")
+          .append("|   |       |   |___mergeReader#updateHeap ")
           .append(operationStatistics.get(MERGE_READER_UPDATE_HEAP))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___mergeReader#fillNullValue ")
+          .append("|   |       |   |___mergeReader#fillNullValue ")
           .append(operationStatistics.get(MERGE_READER_FILL_NULL_VALUE))
           .append(System.lineSeparator());
       builder
-          .append("|   |       |___mergeReader#buildRes ")
+          .append("|   |       |   |___buildTsblock ")
           .append(operationStatistics.get(MERGE_READER_BUILD_RES))
           .append(System.lineSeparator());
+
       builder
           .append("|   |___SendTsBlock ")
           .append(operationStatistics.get(SEND_TSBLOCK))