This is an automated email from the ASF dual-hosted git repository.
jt2594838 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 5b4cad25f Add configurable TsFileInput reader constructor (#869)
5b4cad25f is described below
commit 5b4cad25f6e744ab88a46d50328e7144b1edff11
Author: Jiang Tian <[email protected]>
AuthorDate: Mon Jul 20 19:15:13 2026 +0800
Add configurable TsFileInput reader constructor (#869)
---
.../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 {
