You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tsfile.apache.org by ja...@apache.org on 2025/12/08 06:16:33 UTC
(tsfile) branch develop updated: recover TsFileDeviceIterator.current() #658 Open
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git
The following commit(s) were added to refs/heads/develop by this push:
new 6cda8d69 recover TsFileDeviceIterator.current() #658 Open
6cda8d69 is described below
commit 6cda8d6915edab7265d3e4e421c85e16c14a6cb8
Author: shuwenwei <55...@users.noreply.github.com>
AuthorDate: Mon Dec 8 14:16:28 2025 +0800
recover TsFileDeviceIterator.current() #658 Open
---
.../src/main/java/org/apache/tsfile/read/TsFileDeviceIterator.java | 6 ++++++
.../test/java/org/apache/tsfile/read/TsFileDeviceIteratorTest.java | 2 ++
2 files changed, 8 insertions(+)
diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileDeviceIterator.java b/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileDeviceIterator.java
index 781d233e..9086a9ea 100644
--- a/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileDeviceIterator.java
+++ b/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileDeviceIterator.java
@@ -41,6 +41,12 @@ public class TsFileDeviceIterator implements Iterator<Pair<IDeviceID, Boolean>>
this.lazyTsFileDeviceIterator = new LazyTsFileDeviceIterator(reader, tableName, ioSizeRecorder);
}
+ public Pair<IDeviceID, Boolean> current() throws IOException {
+ return new Pair<>(
+ lazyTsFileDeviceIterator.getCurrentDeviceID(),
+ lazyTsFileDeviceIterator.isCurrentDeviceAligned());
+ }
+
@Override
public boolean hasNext() {
return lazyTsFileDeviceIterator.hasNext();
diff --git a/java/tsfile/src/test/java/org/apache/tsfile/read/TsFileDeviceIteratorTest.java b/java/tsfile/src/test/java/org/apache/tsfile/read/TsFileDeviceIteratorTest.java
index 5e73ed82..6d5870c1 100644
--- a/java/tsfile/src/test/java/org/apache/tsfile/read/TsFileDeviceIteratorTest.java
+++ b/java/tsfile/src/test/java/org/apache/tsfile/read/TsFileDeviceIteratorTest.java
@@ -76,6 +76,7 @@ public class TsFileDeviceIteratorTest {
IDeviceID previous = null;
while (deviceIterator.hasNext()) {
Pair<IDeviceID, Boolean> next = deviceIterator.next();
+ Assert.assertEquals(next, deviceIterator.current());
deviceFromIterator++;
if (previous != null) {
Assert.assertTrue(previous.compareTo(next.getLeft()) < 0);
@@ -89,6 +90,7 @@ public class TsFileDeviceIteratorTest {
previous = null;
while (deviceIterator.hasNext()) {
Pair<IDeviceID, Boolean> next = deviceIterator.next();
+ Assert.assertEquals(next, deviceIterator.current());
deviceFromIterator++;
if (previous != null) {
Assert.assertTrue(previous.compareTo(next.getLeft()) < 0);