[FLINK-36311][format/avro] Remove deprecated APIs in Flink Avro format

nicusX · Sep 25, 2024 · de40ebe · de40ebe
1 parent 42d918d
commit de40ebe
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 407 deletions.
diff --git a/...flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java b/...flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java
@@ -21,8 +21,8 @@
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.common.typeinfo.Types;
 import org.apache.flink.api.java.typeutils.RowTypeInfo;
-import org.apache.flink.formats.avro.AvroRowDeserializationSchema;
-import org.apache.flink.formats.avro.AvroRowSerializationSchema;
+import org.apache.flink.formats.avro.AvroRowDataDeserializationSchema;
+import org.apache.flink.formats.avro.AvroRowDataSerializationSchema;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.types.AtomicDataType;
 import org.apache.flink.table.types.DataType;
@@ -56,7 +56,7 @@
  * SQL API.
  *
  * <p>Note: Changes in this class need to be kept in sync with the corresponding runtime classes
- * {@link AvroRowDeserializationSchema} and {@link AvroRowSerializationSchema}.
+ * {@link AvroRowDataDeserializationSchema} and {@link AvroRowDataSerializationSchema}.
  */
 public class AvroSchemaConverter {
 

diff --git a/...mats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java b/...mats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
@@ -137,13 +137,6 @@ public AvroSerializer(Class<T> type, Schema schema) {
         this.previousSchema = checkNotNull(previousSchema);
     }
 
-    /** @deprecated Use {@link AvroSerializer#AvroSerializer(Class)} instead. */
-    @Deprecated
-    @SuppressWarnings("unused")
-    public AvroSerializer(Class<T> type, Class<? extends T> typeToInstantiate) {
-        this(type);
-    }
-
     // ------------------------------------------------------------------------
 
     @Nonnull
@@ -367,17 +360,6 @@ Schema getAvroSchema() {
     //  Serializer Snapshots
     // ------------------------------------------------------------------------
 
-    /**
-     * A config snapshot for the Avro Serializer that stores the Avro Schema to check compatibility.
-     * This class is now deprecated and only kept for backward comparability.
-     */
-    @Deprecated
-    public static final class AvroSchemaSerializerConfigSnapshot<T>
-            extends AvroSerializerSnapshot<T> {
-
-        public AvroSchemaSerializerConfigSnapshot() {}
-    }
-
     // -------- backwards compatibility with 1.5, 1.6 -----------
 
     private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException {