[flink] 01/02: [hotfix][table-common] ConstraintArgumentTypeStrategy uses Predicate rather than function

[twalthr]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 8aebfb16d028d48ca950709352799b23dbb8ab00
Author: slinkydeveloper <francescogu...@gmail.com>
AuthorDate: Tue Mar 22 08:59:01 2022 +0100

    [hotfix][table-common] ConstraintArgumentTypeStrategy uses Predicate rather 
than function
---
 .../apache/flink/table/types/inference/InputTypeStrategies.java   | 4 ++--
 .../inference/strategies/ConstraintArgumentTypeStrategy.java      | 8 ++++----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/InputTypeStrategies.java
 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/InputTypeStrategies.java
index a9d1251e91e..2f3feea6259 100644
--- 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/InputTypeStrategies.java
+++ 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/InputTypeStrategies.java
@@ -48,7 +48,7 @@ import 
org.apache.flink.table.types.logical.StructuredType.StructuredComparison;
 
 import java.util.Arrays;
 import java.util.List;
-import java.util.function.Function;
+import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
 /**
@@ -268,7 +268,7 @@ public final class InputTypeStrategies {
 
     /** Strategy for an argument that must fulfill a given constraint. */
     public static ConstraintArgumentTypeStrategy constraint(
-            String constraintMessage, Function<List<DataType>, Boolean> 
evaluator) {
+            String constraintMessage, Predicate<List<DataType>> evaluator) {
         return new ConstraintArgumentTypeStrategy(constraintMessage, 
evaluator);
     }
 
diff --git 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java
 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java
index f938e4d3a2e..40c83bcb0d4 100644
--- 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java
+++ 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java
@@ -28,7 +28,7 @@ import 
org.apache.flink.table.types.inference.Signature.Argument;
 import java.util.List;
 import java.util.Objects;
 import java.util.Optional;
-import java.util.function.Function;
+import java.util.function.Predicate;
 
 /** Strategy for an argument that must fulfill a given constraint. */
 @Internal
@@ -36,10 +36,10 @@ public final class ConstraintArgumentTypeStrategy 
implements ArgumentTypeStrateg
 
     private final String constraintMessage;
 
-    private final Function<List<DataType>, Boolean> evaluator;
+    private final Predicate<List<DataType>> evaluator;
 
     public ConstraintArgumentTypeStrategy(
-            String constraintMessage, Function<List<DataType>, Boolean> 
evaluator) {
+            String constraintMessage, Predicate<List<DataType>> evaluator) {
         this.constraintMessage = constraintMessage;
         this.evaluator = evaluator;
     }
@@ -50,7 +50,7 @@ public final class ConstraintArgumentTypeStrategy implements 
ArgumentTypeStrateg
         final List<DataType> actualDataTypes = 
callContext.getArgumentDataTypes();
 
         // type fulfills constraint
-        if (evaluator.apply(actualDataTypes)) {
+        if (evaluator.test(actualDataTypes)) {
             return Optional.of(actualDataTypes.get(argumentPos));
         }