[FLINK-3992][core] Do not implement deprecated Key interface

reswqa · Sep 27, 2024 · 21092bf · 21092bf
1 parent cc0a8b3
commit 21092bf
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java b/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java
@@ -32,8 +32,7 @@
 public class DoubleValue
         implements Comparable<DoubleValue>,
                 ResettableValue<DoubleValue>,
-                CopyableValue<DoubleValue>,
-                Key<DoubleValue> {
+                CopyableValue<DoubleValue> {
     private static final long serialVersionUID = 1L;
 
     private double value;

diff --git a/flink-core/src/main/java/org/apache/flink/types/FloatValue.java b/flink-core/src/main/java/org/apache/flink/types/FloatValue.java
@@ -30,10 +30,7 @@
  */
 @Public
 public class FloatValue
-        implements Comparable<FloatValue>,
-                ResettableValue<FloatValue>,
-                CopyableValue<FloatValue>,
-                Key<FloatValue> {
+        implements Comparable<FloatValue>, ResettableValue<FloatValue>, CopyableValue<FloatValue> {
     private static final long serialVersionUID = 1L;
 
     private float value;

diff --git a/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java b/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java
@@ -34,7 +34,7 @@
  * normalized key length.
  */
 @Public
-public interface NormalizableKey<T> extends Comparable<T>, Key<T> {
+public interface NormalizableKey<T> extends Comparable<T> {
 
     /**
      * Gets the maximal length of normalized keys that the data type would produce to determine the

diff --git a/pom.xml b/pom.xml
@@ -2393,6 +2393,10 @@ under the License.
 								<exclude>
 									org.apache.flink.api.common.functions.RuntimeContext#getExecutionConfig()
 								</exclude>
+								<!-- FLINK-3992 Do not implement deprecated Key interface in flink 2.0 -->
+								<exclude>org.apache.flink.types.DoubleValue</exclude>
+								<exclude>org.apache.flink.types.FloatValue</exclude>
+								<exclude>org.apache.flink.types.NormalizableKey</exclude>
 								<!-- FLINK-5336 Remove IOReadableWritable from Path in flink-2.0. -->
 								<exclude>org.apache.flink.core.fs.Path</exclude>
 								<!-- The following exclusions are due to the flink-hadoop-compatibility_${scala.binary.version} module has renamed to flink-hadoop-compatibility. -->