(tsfile) branch develop updated: Add column builder compatibility (#367)

[haonan]

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

haonan 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 6ced6e19 Add column builder compatibility (#367)
6ced6e19 is described below

commit 6ced6e19e8d2d82140627a3547b47e928c23e1da
Author: Jiang Tian <jt2594...@163.com>
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) {