You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tsfile.apache.org by ji...@apache.org on 2026/07/20 09:34:29 UTC
(tsfile) 01/01: Add configurable TsFileInput reader constructor
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 <jt...@163.com>
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 {