This is an automated email from the ASF dual-hosted git repository. jt2594838 pushed a commit to branch add-tsfile-input-reader-constructor in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit 0bce19aa9202cab6df521226957f2ab5210c171e Author: Tian Jiang <[email protected]> AuthorDate: Mon Jul 20 17:33:57 2026 +0800 Add configurable TsFileInput reader constructor --- .../apache/tsfile/read/TsFileSequenceReader.java | 24 ++++++++++++++++++++++ 1 file changed, 24 insertions(+) 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 97dcddc0d..1fcabdab6 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 @@ -387,6 +387,30 @@ public class TsFileSequenceReader implements AutoCloseable { } } + public TsFileSequenceReader( + TsFileInput input, + boolean loadMetadataSize, + boolean cacheDeviceMetadata, + LongConsumer ioSizeRecorder) + throws IOException { + this.tsFileInput = input; + this.file = input.getFilePath(); + this.cacheDeviceMetadata = cacheDeviceMetadata; + if (resourceLogger.isDebugEnabled()) { + resourceLogger.debug("{} reader is opened. {}", file, getClass().getName()); + } + + try { + loadFileVersion(ioSizeRecorder); + if (loadMetadataSize) { + loadMetadataSize(ioSizeRecorder); + } + } catch (Throwable e) { + tsFileInput.close(); + throw e; + } + } + public TsFileSequenceReader( TsFileInput input, boolean loadMetadataSize, EncryptParameter firstEncryptParam) throws IOException {
