(tsfile) branch develop updated: Rollback method implement of RunLengthEncodedColumn

[jackietien]

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

jackietien 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 0b3886c6 Rollback method implement of RunLengthEncodedColumn
0b3886c6 is described below

commit 0b3886c641370fa85abaee81b8fa1a39aa3f240a
Author: Weihao Li <60659567+wei-hao...@users.noreply.github.com>
AuthorDate: Thu Jan 9 19:55:33 2025 +0800

    Rollback method implement of RunLengthEncodedColumn
---
 .../block/column/RunLengthEncodedColumn.java       | 42 ++++++++++++++++++++++
 1 file changed, 42 insertions(+)

diff --git 
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/RunLengthEncodedColumn.java
 
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/RunLengthEncodedColumn.java
index 6a546586..62037818 100644
--- 
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/RunLengthEncodedColumn.java
+++ 
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/RunLengthEncodedColumn.java
@@ -119,6 +119,48 @@ public class RunLengthEncodedColumn implements Column {
     return res;
   }
 
+  @Override
+  public int[] getInts() {
+    int[] res = new int[positionCount];
+    Arrays.fill(res, value.getInt(0));
+    return res;
+  }
+
+  @Override
+  public long[] getLongs() {
+    long[] res = new long[positionCount];
+    Arrays.fill(res, value.getLong(0));
+    return res;
+  }
+
+  @Override
+  public float[] getFloats() {
+    float[] res = new float[positionCount];
+    Arrays.fill(res, value.getFloat(0));
+    return res;
+  }
+
+  @Override
+  public double[] getDoubles() {
+    double[] res = new double[positionCount];
+    Arrays.fill(res, value.getDouble(0));
+    return res;
+  }
+
+  @Override
+  public Binary[] getBinaries() {
+    Binary[] res = new Binary[positionCount];
+    Arrays.fill(res, value.getBinary(0));
+    return res;
+  }
+
+  @Override
+  public Object[] getObjects() {
+    Object[] res = new Object[positionCount];
+    Arrays.fill(res, value.getObject(0));
+    return res;
+  }
+
   @Override
   public TsPrimitiveType getTsPrimitiveType(int position) {
     return value.getTsPrimitiveType(0);