You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tsfile.apache.org by ji...@apache.org on 2025/01/07 11:00:30 UTC
(tsfile) branch column_builder_compatibility created (now dafda8cf)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch column_builder_compatibility
in repository https://gitbox.apache.org/repos/asf/tsfile.git
at dafda8cf Add column builder compatibility
This branch includes the following new commits:
new dafda8cf Add column builder compatibility
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(tsfile) 01/01: Add column builder compatibility
Posted by ji...@apache.org.
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 <jt...@163.com>
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) {