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/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new e7eed4d [hotfix] Make Predicates Serializable
e7eed4d is described below
commit e7eed4d9f25068b76112296f4717a2194486c510
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Wed Jan 26 13:39:30 2022 +0800
[hotfix] Make Predicates Serializable
---
.../main/java/org/apache/flink/table/store/file/predicate/And.java | 2 ++
.../main/java/org/apache/flink/table/store/file/predicate/Equal.java | 2 ++
.../org/apache/flink/table/store/file/predicate/GreaterOrEqual.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/GreaterThan.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/IsNotNull.java | 2 ++
.../main/java/org/apache/flink/table/store/file/predicate/IsNull.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/LessOrEqual.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/LessThan.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/NotEqual.java | 2 ++
.../src/main/java/org/apache/flink/table/store/file/predicate/Or.java | 2 ++
.../java/org/apache/flink/table/store/file/predicate/Predicate.java | 4 +++-
11 files changed, 23 insertions(+), 1 deletion(-)
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/And.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/And.java
index b926902..5c2817a 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/And.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/And.java
@@ -23,6 +23,8 @@ import org.apache.flink.table.store.file.stats.FieldStats;
/** A {@link Predicate} to eval and. */
public class And implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final Predicate predicate1;
private final Predicate predicate2;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
index cfec2e1..56fc91d 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval equal. */
public class Equal implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterOrEqual.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterOrEqual.java
index 9188b5d..79a0cdc 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterOrEqual.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterOrEqual.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval greater or equal. */
public class GreaterOrEqual implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterThan.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterThan.java
index 25d24ac..81ddc26 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterThan.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/GreaterThan.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval greater. */
public class GreaterThan implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNotNull.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNotNull.java
index 7cb9a3e..9de7d5b 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNotNull.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNotNull.java
@@ -23,6 +23,8 @@ import org.apache.flink.table.store.file.stats.FieldStats;
/** A {@link Predicate} to eval is not null. */
public class IsNotNull implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
public IsNotNull(int index) {
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNull.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNull.java
index e3df845..5e9461a 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNull.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/IsNull.java
@@ -23,6 +23,8 @@ import org.apache.flink.table.store.file.stats.FieldStats;
/** A {@link Predicate} to eval is null. */
public class IsNull implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
public IsNull(int index) {
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessOrEqual.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessOrEqual.java
index ed7695c..9a94190 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessOrEqual.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessOrEqual.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval less or equal. */
public class LessOrEqual implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessThan.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessThan.java
index 2e644c0..f8fda69 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessThan.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/LessThan.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval less. */
public class LessThan implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/NotEqual.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/NotEqual.java
index 94232a9..2c2136a 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/NotEqual.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/NotEqual.java
@@ -25,6 +25,8 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
/** A {@link Predicate} to eval not equal. */
public class NotEqual implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final int index;
private final Literal literal;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Or.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Or.java
index 6fd264f..02a79b1 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Or.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Or.java
@@ -23,6 +23,8 @@ import org.apache.flink.table.store.file.stats.FieldStats;
/** A {@link Predicate} to eval or. */
public class Or implements Predicate {
+ private static final long serialVersionUID = 1L;
+
private final Predicate predicate1;
private final Predicate predicate2;
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Predicate.java
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Predicate.java
index 6edb261..b1db20d 100644
---
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Predicate.java
+++
b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Predicate.java
@@ -20,8 +20,10 @@ package org.apache.flink.table.store.file.predicate;
import org.apache.flink.table.store.file.stats.FieldStats;
+import java.io.Serializable;
+
/** Predicate which returns Boolean and provides testing by stats. */
-public interface Predicate {
+public interface Predicate extends Serializable {
/**
* Test based on the specific input column values.
