This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 1b09de943 [core] Add serial version for aggr functions (#4252)
1b09de943 is described below
commit 1b09de94346c07286d8174a4393535c36135580b
Author: Jie Feng <[email protected]>
AuthorDate: Wed Sep 25 12:02:57 2024 +0800
[core] Add serial version for aggr functions (#4252)
---
.../org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java | 2 ++
.../paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java | 2 ++
.../paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java | 2 ++
.../apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java | 2 ++
.../java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java | 2 ++
.../java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java | 2 ++
.../apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java | 2 ++
.../apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java | 2 ++
.../org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java | 2 ++
.../java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java | 2 ++
15 files changed, 30 insertions(+)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java
index 8fcdb14a6..2737c691d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java
@@ -37,6 +37,8 @@ import static
org.apache.paimon.utils.Preconditions.checkArgument;
public abstract class FieldAggregator implements Serializable {
protected DataType fieldType;
+ private static final long serialVersionUID = 1L;
+
public FieldAggregator(DataType dataType) {
this.fieldType = dataType;
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java
index 91bdd053b..0b6371309 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java
@@ -25,6 +25,8 @@ public class FieldBoolAndAgg extends FieldAggregator {
public static final String NAME = "bool_and";
+ private static final long serialVersionUID = 1L;
+
public FieldBoolAndAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java
index b3bee58a8..ae385b3cc 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java
@@ -25,6 +25,8 @@ public class FieldBoolOrAgg extends FieldAggregator {
public static final String NAME = "bool_or";
+ private static final long serialVersionUID = 1L;
+
public FieldBoolOrAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java
index 590c3d0b6..ddfae4de2 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java
@@ -45,6 +45,8 @@ public class FieldCollectAgg extends FieldAggregator {
public static final String NAME = "collect";
+ private static final long serialVersionUID = 1L;
+
private final boolean distinct;
private final InternalArray.ElementGetter elementGetter;
@Nullable private final BiFunction<Object, Object, Boolean> equaliser;
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java
index 7fe531378..83f3f72a2 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java
@@ -23,6 +23,8 @@ public class FieldIgnoreRetractAgg extends FieldAggregator {
private final FieldAggregator aggregator;
+ private static final long serialVersionUID = 1L;
+
public FieldIgnoreRetractAgg(FieldAggregator aggregator) {
super(aggregator.fieldType);
this.aggregator = aggregator;
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java
index bb563b70f..f069a914d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java
@@ -25,6 +25,8 @@ public class FieldLastNonNullValueAgg extends FieldAggregator
{
public static final String NAME = "last_non_null_value";
+ private static final long serialVersionUID = 1L;
+
public FieldLastNonNullValueAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java
index bc6812346..9a4a5d4de 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java
@@ -25,6 +25,8 @@ public class FieldLastValueAgg extends FieldAggregator {
public static final String NAME = "last_value";
+ private static final long serialVersionUID = 1L;
+
public FieldLastValueAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java
index e0286bbb7..25ee8cc24 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java
@@ -28,6 +28,8 @@ public class FieldListaggAgg extends FieldAggregator {
public static final String NAME = "listagg";
+ private static final long serialVersionUID = 1L;
+
private final String delimiter;
public FieldListaggAgg(DataType dataType, CoreOptions options, String
field) {
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java
index e394ee855..292c29510 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java
@@ -27,6 +27,8 @@ public class FieldMaxAgg extends FieldAggregator {
public static final String NAME = "max";
+ private static final long serialVersionUID = 1L;
+
public FieldMaxAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java
index 9042adc51..8ba78ad5e 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java
@@ -33,6 +33,8 @@ public class FieldMergeMapAgg extends FieldAggregator {
public static final String NAME = "merge_map";
+ private static final long serialVersionUID = 1L;
+
private final InternalArray.ElementGetter keyGetter;
private final InternalArray.ElementGetter valueGetter;
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java
index faf7ce709..403724f25 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java
@@ -27,6 +27,8 @@ public class FieldMinAgg extends FieldAggregator {
public static final String NAME = "min";
+ private static final long serialVersionUID = 1L;
+
public FieldMinAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
index affc79417..1f725bb7d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
@@ -46,6 +46,8 @@ public class FieldNestedUpdateAgg extends FieldAggregator {
public static final String NAME = "nested_update";
+ private static final long serialVersionUID = 1L;
+
private final int nestedFields;
@Nullable private final Projection keyProjection;
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java
index 6572f0693..58961bc5a 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java
@@ -25,6 +25,8 @@ public class FieldPrimaryKeyAgg extends FieldAggregator {
public static final String NAME = "primary-key";
+ private static final long serialVersionUID = 1L;
+
public FieldPrimaryKeyAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java
index d1b9172bc..1a0200246 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java
@@ -30,6 +30,8 @@ public class FieldProductAgg extends FieldAggregator {
public static final String NAME = "product";
+ private static final long serialVersionUID = 1L;
+
public FieldProductAgg(DataType dataType) {
super(dataType);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java
index ac8b1c4a2..38081e20e 100644
---
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java
+++
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java
@@ -27,6 +27,8 @@ public class FieldSumAgg extends FieldAggregator {
public static final String NAME = "sum";
+ private static final long serialVersionUID = 1L;
+
public FieldSumAgg(DataType dataType) {
super(dataType);
}
