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


The following commit(s) were added to refs/heads/lmh/groupByTest by this push:
     new db5cb0dea6 print metric about merge reader
db5cb0dea6 is described below

commit db5cb0dea6aee527c00fb881260319866e6eefe5
Author: Minghui Liu <[email protected]>
AuthorDate: Wed Apr 12 16:13:03 2023 +0800

    print metric about merge reader
---
 .../iotdb/db/mpp/statistics/QueryStatistics.java     | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

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 8e287e34da..e388f02abe 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
@@ -400,6 +400,26 @@ public class QueryStatistics {
           .append("|   |       |___initFirstPage ")
           .append(operationStatistics.get(INIT_FIRST_PAGE))
           .append(System.lineSeparator());
+      builder
+          .append("|   |       |___mergeReader#addReader ")
+          .append(operationStatistics.get(MERGE_READER_ADD_READER))
+          .append(System.lineSeparator());
+      builder
+          .append("|   |       |___mergeReader#nextTimeValuePair ")
+          .append(operationStatistics.get(MERGE_READER_NEXT))
+          .append(System.lineSeparator());
+      builder
+          .append("|   |       |___mergeReader#updateHeap ")
+          .append(operationStatistics.get(MERGE_READER_UPDATE_HEAP))
+          .append(System.lineSeparator());
+      builder
+          .append("|   |       |___mergeReader#fillNullValue ")
+          .append(operationStatistics.get(MERGE_READER_FILL_NULL_VALUE))
+          .append(System.lineSeparator());
+      builder
+          .append("|   |       |___mergeReader#buildRes ")
+          .append(operationStatistics.get(MERGE_READER_BUILD_RES))
+          .append(System.lineSeparator());
       builder
           .append("|   |___SendTsBlock ")
           .append(operationStatistics.get(SEND_TSBLOCK))

Reply via email to