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

leirui pushed a commit to branch research/LTS-visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 603dc93b930dc42dfd7c531e584aab93909cc595
Author: Lei Rui <1010953...@qq.com>
AuthorDate: Sun Jul 14 01:23:48 2024 +0800

    add
---
 .../db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java
 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java
index 322c1f51076..5453d6be36a 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java
@@ -274,6 +274,7 @@ public class GroupByWithoutValueFilterDataSet extends 
GroupByEngineDataSet {
         int cnt = 0;
         for (int j = nextBucket * rps; j < (nextBucket + 1) * rps; j++) {
           if (times.get(j) != null) {
+            IOMonitor2.DCP_D_getAllSatisfiedPageData_traversedPointNum++;
             rt += times.get(j);
             rv += (double) values.get(j);
             cnt++;
@@ -290,6 +291,7 @@ public class GroupByWithoutValueFilterDataSet extends 
GroupByEngineDataSet {
         double select_v = -1;
         for (int j = currentBucket * rps; j < (currentBucket + 1) * rps; j++) {
           if (times.get(j) != null) {
+            IOMonitor2.DCP_D_getAllSatisfiedPageData_traversedPointNum++;
             long t = times.get(j);
             double v = values.get(j);
             double area = IOMonitor2.calculateTri(lt, lv, t, v, rt, rv);
@@ -315,6 +317,7 @@ public class GroupByWithoutValueFilterDataSet extends 
GroupByEngineDataSet {
       double select_v = -1;
       for (int j = currentBucket * rps; j < (currentBucket + 1) * rps; j++) {
         if (times.get(j) != null) {
+          IOMonitor2.DCP_D_getAllSatisfiedPageData_traversedPointNum++;
           long t = times.get(j);
           double v = values.get(j);
           double area = IOMonitor2.calculateTri(lt, lv, t, v, pnt, pnv); // 
全局尾点作为右边固定点

Reply via email to