You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by le...@apache.org on 2024/07/21 15:47:47 UTC
(iotdb) 03/12: add
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 <10...@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); // 全局尾点作为右边固定点