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 2023/04/13 05:51:48 UTC
[iotdb] branch research/M4-visualization updated: add
This is an automated email from the ASF dual-hosted git repository.
leirui pushed a commit to branch research/M4-visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/research/M4-visualization by this push:
new 22f407dcb3 add
22f407dcb3 is described below
commit 22f407dcb3820a29215073e543fcdb131f0bfe7f
Author: Lei Rui <10...@qq.com>
AuthorDate: Thu Apr 13 13:48:39 2023 +0800
add
---
.../java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
index 59ba46ed2c..0834348a26 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ChunkSuit4CPV.java
@@ -503,14 +503,17 @@ public class ChunkSuit4CPV {
// search from estimatePos in the timeBuffer to find the closet timestamp equal to or smaller
// than the given timestamp
int estimatedPos = -1;
+ boolean flag = false;
pageReader.timeBuffer.position(0);
pageReader.valueBuffer.position(pageReader.timeBufferLength);
while (pageReader.timeBuffer.remaining() > 0) {
- estimatedPos++;
- IOMonitor.incPointsTravered();
+ if (!flag) {
+ estimatedPos++;
+ IOMonitor.incPointsTravered();
+ }
long t = pageReader.timeBuffer.getLong();
if (t >= targetTimestamp) {
- break;
+ flag = true;
}
}