This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch column_builder_compatibility in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit dafda8cfe08de958c217efb18202b958d3847a32 Author: Tian Jiang <[email protected]> AuthorDate: Tue Jan 7 19:00:19 2025 +0800 Add column builder compatibility --- .../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) {
