(tsfile) branch snapshot/2.2.0-251208 updated: recover TsFileDeviceIterator.current() #658 Open

[jackietien]

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

jackietien pushed a commit to branch snapshot/2.2.0-251208
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/snapshot/2.2.0-251208 by this 
push:
     new cfff0a45 recover TsFileDeviceIterator.current() #658  Open
cfff0a45 is described below

commit cfff0a4525ffcc64aab4bca1caa0a661877c334f
Author: shuwenwei <55970239+shuwen...@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);