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 7c8305059..6d03a38b4 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 int getPositionCount() { 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 79b2be019..290cb3df2 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 int getPositionCount() { 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 758082b20..6cc22c8bb 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 int getPositionCount() { 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 53d6fdfd0..c76acc9db 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 TimeColumnBuilder(ColumnBuilderStatus columnBuilderStatus, int expectedEn updateDataSize(); } + @Override + public ColumnBuilder writeInt(int value) { + return writeLong(value); + } + @Override public ColumnBuilder writeLong(long value) { if (values.length <= positionCount) {