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)); }