This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch fix_RLBE_construction
in repository https://gitbox.apache.org/repos/asf/tsfile.git

commit 9860001bb8bb2b5b23e7017558166b181bd14874
Author: Tian Jiang <[email protected]>
AuthorDate: Mon Jul 8 11:45:51 2024 +0800

    Fix encoder and decoder construction of RLBE
---
 .../src/main/java/org/apache/tsfile/encoding/decoder/Decoder.java      | 3 ++-
 .../java/org/apache/tsfile/encoding/encoder/TSEncodingBuilder.java     | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/Decoder.java 
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/Decoder.java
index be83a285..36c3d826 100644
--- a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/Decoder.java
+++ b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/Decoder.java
@@ -171,8 +171,9 @@ public abstract class Decoder {
           case TIMESTAMP:
             return new LongRLBEDecoder();
           case FLOAT:
+            return new FloatRLBEDecoder();
           case DOUBLE:
-            return new FloatDecoder(TSEncoding.valueOf(encoding.toString()), 
dataType);
+            return new DoubleRLBEDecoder();
           default:
             throw new TsFileDecodingException(String.format(ERROR_MSG, 
encoding, dataType));
         }
diff --git 
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/TSEncodingBuilder.java
 
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/TSEncodingBuilder.java
index 18889438..7a89c36e 100644
--- 
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/TSEncodingBuilder.java
+++ 
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/TSEncodingBuilder.java
@@ -354,8 +354,9 @@ public abstract class TSEncodingBuilder {
         case TIMESTAMP:
           return new LongRLBE();
         case FLOAT:
+          return new FloatRLBE();
         case DOUBLE:
-          return new FloatEncoder(TSEncoding.RLBE, type, maxPointNumber);
+          return new DoubleRLBE();
         default:
           throw new UnSupportedDataTypeException("RLBE doesn't support data 
type: " + type);
       }

Reply via email to