This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch snapshot/2.0.0-250109 in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit 9b6a18f93faa259558616b0e0c49286c577c2e7e Author: Weihao Li <[email protected]> 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);
