This is an automated email from the ASF dual-hosted git repository. jt2594838 pushed a commit to branch add_interfaces_for_type in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit cc0ba0175f5f9dc7c04b63d686ac29789cf0ecfd Author: Tian Jiang <[email protected]> AuthorDate: Thu Jul 23 15:51:45 2026 +0800 add Type.write --- .../java/org/apache/tsfile/read/common/type/AbstractIntType.java | 4 ++-- .../java/org/apache/tsfile/read/common/type/AbstractLongType.java | 4 ++-- .../org/apache/tsfile/read/common/type/AbstractVarcharType.java | 4 ++-- .../main/java/org/apache/tsfile/read/common/type/BlobType.java | 4 ++-- .../main/java/org/apache/tsfile/read/common/type/BooleanType.java | 4 ++-- .../main/java/org/apache/tsfile/read/common/type/DateType.java | 8 ++++---- .../main/java/org/apache/tsfile/read/common/type/DoubleType.java | 4 ++-- .../main/java/org/apache/tsfile/read/common/type/FloatType.java | 4 ++-- .../main/java/org/apache/tsfile/read/common/type/ObjectType.java | 4 ++-- .../src/main/java/org/apache/tsfile/read/common/type/RowType.java | 4 ++-- .../src/main/java/org/apache/tsfile/read/common/type/Type.java | 2 +- .../main/java/org/apache/tsfile/read/common/type/VectorType.java | 4 ++-- 12 files changed, 25 insertions(+), 25 deletions(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractIntType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractIntType.java index 97c7d0f1a..790337053 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractIntType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractIntType.java @@ -335,8 +335,8 @@ public abstract class AbstractIntType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((int[]) array)[index] = value.getInt(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((int[]) toArray)[index] = from.getInt(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractLongType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractLongType.java index 25da498b5..350244782 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractLongType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractLongType.java @@ -334,8 +334,8 @@ public abstract class AbstractLongType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((long[]) array)[index] = value.getLong(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((long[]) toArray)[index] = from.getLong(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractVarcharType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractVarcharType.java index ebee3bdc3..26620691f 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractVarcharType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/AbstractVarcharType.java @@ -296,8 +296,8 @@ public abstract class AbstractVarcharType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((Binary[]) array)[index] = value.getBinary(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((Binary[]) toArray)[index] = from.getBinary(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BlobType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BlobType.java index 040bdc094..373364602 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BlobType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BlobType.java @@ -314,8 +314,8 @@ public class BlobType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((Binary[]) array)[index] = value.getBinary(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((Binary[]) toArray)[index] = from.getBinary(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BooleanType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BooleanType.java index 32fe1c037..db8b29162 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BooleanType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/BooleanType.java @@ -318,8 +318,8 @@ public class BooleanType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((boolean[]) array)[index] = value.getBoolean(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((boolean[]) toArray)[index] = from.getBoolean(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DateType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DateType.java index 1334f2f38..d823578cc 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DateType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DateType.java @@ -69,12 +69,12 @@ public class DateType extends AbstractIntType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - if (array instanceof int[]) { - super.write(value, array, index); + public void write(TsPrimitiveType from, Object toArray, int index) { + if (toArray instanceof int[]) { + super.write(from, toArray, index); return; } - ((LocalDate[]) array)[index] = DateUtils.parseIntToLocalDate(value.getInt()); + ((LocalDate[]) toArray)[index] = DateUtils.parseIntToLocalDate(from.getInt()); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DoubleType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DoubleType.java index f9093b06c..802e9b0a4 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DoubleType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/DoubleType.java @@ -344,8 +344,8 @@ public class DoubleType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((double[]) array)[index] = value.getDouble(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((double[]) toArray)[index] = from.getDouble(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/FloatType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/FloatType.java index 8d1457e05..fce2a6a82 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/FloatType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/FloatType.java @@ -342,8 +342,8 @@ public class FloatType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((float[]) array)[index] = value.getFloat(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((float[]) toArray)[index] = from.getFloat(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/ObjectType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/ObjectType.java index fa625dc39..cc6fb5197 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/ObjectType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/ObjectType.java @@ -304,8 +304,8 @@ public class ObjectType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((Binary[]) array)[index] = value.getBinary(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((Binary[]) toArray)[index] = from.getBinary(); } @Override diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/RowType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/RowType.java index 5fc6faafa..7b84f7a67 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/RowType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/RowType.java @@ -90,8 +90,8 @@ public class RowType extends AbstractType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((TsPrimitiveType[][]) array)[index] = value.getVector(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((TsPrimitiveType[][]) toArray)[index] = from.getVector(); } public static Field field(String name, Type type) { diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/Type.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/Type.java index 216a263d2..69af1231a 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/Type.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/Type.java @@ -162,7 +162,7 @@ public interface Type { } /** Writes a TsPrimitiveType value to {@code array} at {@code index}. */ - default void write(TsPrimitiveType value, Object array, int index) { + default void write(TsPrimitiveType from, Object toArray, int index) { throw new UnsupportedOperationException(getClass().getName()); } diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/VectorType.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/VectorType.java index fb783f630..aab959c9c 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/VectorType.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/type/VectorType.java @@ -89,8 +89,8 @@ public class VectorType extends AbstractLongType { } @Override - public void write(TsPrimitiveType value, Object array, int index) { - ((TsPrimitiveType[][]) array)[index] = value.getVector(); + public void write(TsPrimitiveType from, Object toArray, int index) { + ((TsPrimitiveType[][]) toArray)[index] = from.getVector(); } @Override
