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 01:44:16 UTC
[iotdb] branch lmh/groupByTest updated: print metric about merge reader
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 <li...@foxmail.com>
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))