(tsfile) branch develop updated: add constructor TsFileDeviceIterator(TsFileSequenceReader reader, String tableName) #608

[jackietien]

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 1db3fe50 add constructor TsFileDeviceIterator(TsFileSequenceReader 
reader, String tableName) #608
1db3fe50 is described below

commit 1db3fe502409cd1036c7a200dd3fbb12e8d775c2
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Mon Oct 27 09:46:54 2025 +0800

    add constructor TsFileDeviceIterator(TsFileSequenceReader reader, String 
tableName) #608
---
 .../java/org/apache/tsfile/read/TsFileDeviceIterator.java    | 12 ++++++++++++
 .../java/org/apache/tsfile/read/TsFileSequenceReader.java    |  5 +++++
 2 files changed, 17 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 3454f5dd..66fd3fbc 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
@@ -35,6 +35,7 @@ import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
+import java.util.Collections;
 import java.util.Iterator;
 import java.util.LinkedList;
 import java.util.List;
@@ -60,6 +61,17 @@ public class TsFileDeviceIterator implements 
Iterator<Pair<IDeviceID, Boolean>>
         
reader.readFileMetadata().getTableMetadataIndexNodeMap().values().iterator();
   }
 
+  public TsFileDeviceIterator(TsFileSequenceReader reader, String tableName) 
throws IOException {
+    this.reader = reader;
+    this.deserializeConfig = reader.getDeserializeContext();
+    MetadataIndexNode tableMetadataIndexNode =
+        reader.readFileMetadata().getTableMetadataIndexNode(tableName);
+    this.tableMetadataIndexNodeIterator =
+        tableMetadataIndexNode == null
+            ? Collections.emptyIterator()
+            : Collections.singleton(tableMetadataIndexNode).iterator();
+  }
+
   public Pair<IDeviceID, Boolean> current() {
     return currentDevice;
   }
diff --git 
a/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java 
b/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
index bde4387c..9c6d8ed4 100644
--- a/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
+++ b/java/tsfile/src/main/java/org/apache/tsfile/read/TsFileSequenceReader.java
@@ -1123,6 +1123,11 @@ public class TsFileSequenceReader implements 
AutoCloseable {
     return new TsFileDeviceIterator(this);
   }
 
+  public TsFileDeviceIterator getTableDevicesIteratorWithIsAligned(String 
tableName)
+      throws IOException {
+    return new TsFileDeviceIterator(this);
+  }
+
   /**
    * read all ChunkMetaDatas of given device
    *