This is an automated email from the ASF dual-hosted git repository.
jackietien 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 1869d788 Add interface ColumnBuilder#getPositionCount
1869d788 is described below
commit 1869d78868b9acb7eead16f9b2127df8b5ce9395
Author: Chen YZ <[email protected]>
AuthorDate: Sat Jan 4 19:16:58 2025 +0800
Add interface ColumnBuilder#getPositionCount
---
.../src/main/java/org/apache/tsfile/block/column/ColumnBuilder.java | 2 ++
.../apache/tsfile/read/common/block/column/BinaryColumnBuilder.java | 5 +++++
.../apache/tsfile/read/common/block/column/BooleanColumnBuilder.java | 5 +++++
.../apache/tsfile/read/common/block/column/DoubleColumnBuilder.java | 5 +++++
.../apache/tsfile/read/common/block/column/FloatColumnBuilder.java | 5 +++++
.../org/apache/tsfile/read/common/block/column/IntColumnBuilder.java | 5 +++++
.../apache/tsfile/read/common/block/column/LongColumnBuilder.java | 5 +++++
7 files changed, 32 insertions(+)
diff --git
a/java/common/src/main/java/org/apache/tsfile/block/column/ColumnBuilder.java
b/java/common/src/main/java/org/apache/tsfile/block/column/ColumnBuilder.java
index df8ecc11..1175439e 100644
---
a/java/common/src/main/java/org/apache/tsfile/block/column/ColumnBuilder.java
+++
b/java/common/src/main/java/org/apache/tsfile/block/column/ColumnBuilder.java
@@ -24,6 +24,8 @@ import org.apache.tsfile.utils.Binary;
import org.apache.tsfile.utils.TsPrimitiveType;
public interface ColumnBuilder {
+ /** Returns the number of positions in this block builder. */
+ int getPositionCount();
/** Write a boolean to the current entry; */
default ColumnBuilder writeBoolean(boolean value) {
diff --git
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BinaryColumnBuilder.java
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BinaryColumnBuilder.java
index 917c6e5f..a82d82fc 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BinaryColumnBuilder.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BinaryColumnBuilder.java
@@ -63,6 +63,11 @@ public class BinaryColumnBuilder implements ColumnBuilder {
updateArraysDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@Override
public ColumnBuilder writeBinary(Binary value) {
if (values.length <= positionCount) {
diff --git
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BooleanColumnBuilder.java
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BooleanColumnBuilder.java
index 3516b394..88735876 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BooleanColumnBuilder.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/BooleanColumnBuilder.java
@@ -61,6 +61,11 @@ public class BooleanColumnBuilder implements ColumnBuilder {
updateDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@Override
public ColumnBuilder writeBoolean(boolean value) {
if (values.length <= positionCount) {
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 7e02cf01..7c830505 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
@@ -61,6 +61,11 @@ public class DoubleColumnBuilder implements ColumnBuilder {
updateDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@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 bdb5e593..79b2be01 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
@@ -61,6 +61,11 @@ public class FloatColumnBuilder implements ColumnBuilder {
updateDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@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/IntColumnBuilder.java
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/IntColumnBuilder.java
index 4148ad7b..a0fc7a5b 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/IntColumnBuilder.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/IntColumnBuilder.java
@@ -63,6 +63,11 @@ public class IntColumnBuilder implements ColumnBuilder {
updateDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@Override
public ColumnBuilder writeInt(int 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 b0f4d952..758082b2 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
@@ -61,6 +61,11 @@ public class LongColumnBuilder implements ColumnBuilder {
updateDataSize();
}
+ @Override
+ public int getPositionCount() {
+ return positionCount;
+ }
+
@Override
public ColumnBuilder writeLong(long value) {
if (values.length <= positionCount) {
