You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/09/20 08:37:12 UTC
[iotdb] branch tsfile_read created (now f6c93b8712)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch tsfile_read
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at f6c93b8712 AlignedChunkReader should uncompress value page by the compress type in chunkHeader
This branch includes the following new commits:
new f6c93b8712 AlignedChunkReader should uncompress value page by the compress type in chunkHeader
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: AlignedChunkReader should uncompress value page by the compress type in chunkHeader
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch tsfile_read
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f6c93b87124a3c5d85ef0dd06099f5323bba3af0
Author: HTHou <hh...@outlook.com>
AuthorDate: Tue Sep 20 16:36:52 2022 +0800
AlignedChunkReader should uncompress value page by the compress type in chunkHeader
---
.../org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReader.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReader.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReader.java
index fa75cd1f14..c18c9064bb 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReader.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReader.java
@@ -278,6 +278,7 @@ public class AlignedChunkReader implements IChunkReader {
Decoder.getDecoderByType(chunkHeader.getEncodingType(), chunkHeader.getDataType());
byte[] uncompressedPageData = new byte[pageHeader.getUncompressedSize()];
try {
+ IUnCompressor unCompressor = IUnCompressor.getUnCompressor(chunkHeader.getCompressionType());
unCompressor.uncompress(
compressedPageBody, 0, compressedPageBodyLength, uncompressedPageData, 0);
} catch (Exception e) {