(tsfile) branch develop updated: IntColumnBuilder support write LocalDate Object

[jackietien]

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 4a9eeaf6 IntColumnBuilder support write LocalDate Object
4a9eeaf6 is described below

commit 4a9eeaf6a8183f2bcd6a59acdd1c6baf0af49952
Author: Chen YZ <43774645+cpau...@users.noreply.github.com>
AuthorDate: Fri Nov 29 12:11:27 2024 +0800

    IntColumnBuilder support write LocalDate Object
---
 .../org/apache/tsfile/read/common/block/column/IntColumnBuilder.java | 5 +++++
 1 file changed, 5 insertions(+)

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 e78eac1d..4148ad7b 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
@@ -23,10 +23,12 @@ import org.apache.tsfile.block.column.Column;
 import org.apache.tsfile.block.column.ColumnBuilder;
 import org.apache.tsfile.block.column.ColumnBuilderStatus;
 import org.apache.tsfile.enums.TSDataType;
+import org.apache.tsfile.utils.DateUtils;
 import org.apache.tsfile.utils.RamUsageEstimator;
 import org.apache.tsfile.utils.TsPrimitiveType;
 import org.apache.tsfile.write.UnSupportedDataTypeException;
 
+import java.time.LocalDate;
 import java.util.Arrays;
 
 import static java.lang.Math.max;
@@ -83,6 +85,9 @@ public class IntColumnBuilder implements ColumnBuilder {
     if (value instanceof Integer) {
       writeInt((Integer) value);
       return this;
+    } else if (value instanceof LocalDate) {
+      writeInt(DateUtils.parseDateExpressionToInt((LocalDate) value));
+      return this;
     }
     throw new UnSupportedDataTypeException("IntegerColumn only support Integer 
data type");
   }