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 22ec6490333f88518af51e9c651fa5514da6919e Author: Jiang Tian <[email protected]> AuthorDate: Thu Jan 9 11:25:13 2025 +0800 Add column builder compatibility (#367) --- .../read/common/block/column/DoubleColumnBuilder.java | 15 +++++++++++++++ .../read/common/block/column/FloatColumnBuilder.java | 5 +++++ .../read/common/block/column/LongColumnBuilder.java | 5 +++++ .../read/common/block/column/TimeColumnBuilder.java | 5 +++++ 4 files changed, 30 insertions(+) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/DoubleColumnBuilder.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/DoubleColumnBuilder.java index 7c830505..6d03a38b 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/DoubleColumnBuilder.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/DoubleColumnBuilder.java @@ -66,6 +66,21 @@ public class DoubleColumnBuilder implements ColumnBuilder { return positionCount; } + @Override + public ColumnBuilder writeLong(long value) { + return writeDouble(value); + } + + @Override + public ColumnBuilder writeFloat(float value) { + return writeDouble(value); + } + + @Override + public ColumnBuilder writeInt(int value) { + return writeDouble(value); + } + @Override public ColumnBuilder writeDouble(double value) { if (values.length <= positionCount) { diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/FloatColumnBuilder.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/FloatColumnBuilder.java index 79b2be01..290cb3df 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/FloatColumnBuilder.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/FloatColumnBuilder.java @@ -66,6 +66,11 @@ public class FloatColumnBuilder implements ColumnBuilder { return positionCount; } + @Override + public ColumnBuilder writeInt(int value) { + return writeFloat(value); + } + @Override public ColumnBuilder writeFloat(float value) { if (values.length <= positionCount) { diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/LongColumnBuilder.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/LongColumnBuilder.java index 758082b2..6cc22c8b 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/LongColumnBuilder.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/LongColumnBuilder.java @@ -66,6 +66,11 @@ public class LongColumnBuilder implements ColumnBuilder { return positionCount; } + @Override + public ColumnBuilder writeInt(int value) { + return writeLong(value); + } + @Override public ColumnBuilder writeLong(long value) { if (values.length <= positionCount) { diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TimeColumnBuilder.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TimeColumnBuilder.java index 53d6fdfd..c76acc9d 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TimeColumnBuilder.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TimeColumnBuilder.java @@ -54,6 +54,11 @@ public class TimeColumnBuilder implements ColumnBuilder { updateDataSize(); } + @Override + public ColumnBuilder writeInt(int value) { + return writeLong(value); + } + @Override public ColumnBuilder writeLong(long value) { if (values.length <= positionCount) {
