Skip to content

Commit 22ec649

Browse files
jt2594838JackieTien97
authored andcommitted
Add column builder compatibility (#367)
1 parent 12bbf56 commit 22ec649

4 files changed

Lines changed: 30 additions & 0 deletions

File tree

java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/DoubleColumnBuilder.java

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,21 @@ public int getPositionCount() {
6666
return positionCount;
6767
}
6868

69+
@Override
70+
public ColumnBuilder writeLong(long value) {
71+
return writeDouble(value);
72+
}
73+
74+
@Override
75+
public ColumnBuilder writeFloat(float value) {
76+
return writeDouble(value);
77+
}
78+
79+
@Override
80+
public ColumnBuilder writeInt(int value) {
81+
return writeDouble(value);
82+
}
83+
6984
@Override
7085
public ColumnBuilder writeDouble(double value) {
7186
if (values.length <= positionCount) {

java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/FloatColumnBuilder.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,11 @@ public int getPositionCount() {
6666
return positionCount;
6767
}
6868

69+
@Override
70+
public ColumnBuilder writeInt(int value) {
71+
return writeFloat(value);
72+
}
73+
6974
@Override
7075
public ColumnBuilder writeFloat(float value) {
7176
if (values.length <= positionCount) {

java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/LongColumnBuilder.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,11 @@ public int getPositionCount() {
6666
return positionCount;
6767
}
6868

69+
@Override
70+
public ColumnBuilder writeInt(int value) {
71+
return writeLong(value);
72+
}
73+
6974
@Override
7075
public ColumnBuilder writeLong(long value) {
7176
if (values.length <= positionCount) {

java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TimeColumnBuilder.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,11 @@ public TimeColumnBuilder(ColumnBuilderStatus columnBuilderStatus, int expectedEn
5454
updateDataSize();
5555
}
5656

57+
@Override
58+
public ColumnBuilder writeInt(int value) {
59+
return writeLong(value);
60+
}
61+
5762
@Override
5863
public ColumnBuilder writeLong(long value) {
5964
if (values.length <= positionCount) {

0 commit comments

Comments
 (0)