[FLINK-36311][format/csv] Remove deprecated APIs in Flink Csv format

dianfu · Sep 18, 2024 · 0f1118b · 0f1118b
1 parent a6895b6
commit 0f1118b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 14 deletions.
diff --git a/...mats/csv/CsvRowDeserializationSchema.java → ...mats/csv/CsvRowDeserializationSchema.java b/...mats/csv/CsvRowDeserializationSchema.java → ...mats/csv/CsvRowDeserializationSchema.java
@@ -18,7 +18,7 @@
 
 package org.apache.flink.formats.csv;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.serialization.DeserializationSchema;
 import org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo;
 import org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo;
@@ -57,13 +57,8 @@
  * Row}.
  *
  * <p>Failure during deserialization are forwarded as wrapped {@link IOException}s.
- *
- * @deprecated The format was developed for the Table API users and will not be maintained for
- *     DataStream API users anymore. Either use Table API or switch to Data Stream, defining your
- *     own {@link DeserializationSchema}.
  */
-@PublicEvolving
-@Deprecated
+@Internal
 public final class CsvRowDeserializationSchema implements DeserializationSchema<Row> {
 
     private static final long serialVersionUID = 2135553495874539201L;

diff --git a/...ormats/csv/CsvRowSerializationSchema.java → ...ormats/csv/CsvRowSerializationSchema.java b/...ormats/csv/CsvRowSerializationSchema.java → ...ormats/csv/CsvRowSerializationSchema.java
@@ -18,7 +18,7 @@
 
 package org.apache.flink.formats.csv;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.serialization.SerializationSchema;
 import org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo;
 import org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo;
@@ -57,13 +57,8 @@
  *
  * <p>Result <code>byte[]</code> messages can be deserialized using {@link
  * CsvRowDeserializationSchema}.
- *
- * @deprecated The format was developed for the Table API users and will not be maintained for
- *     DataStream API users anymore. Either use Table API or switch to Data Stream, defining your
- *     own {@link SerializationSchema}.
  */
-@PublicEvolving
-@Deprecated
+@Internal
 public final class CsvRowSerializationSchema implements SerializationSchema<Row> {
 
     private static final long serialVersionUID = 2098447220136965L;

diff --git a/.../csv/CsvRowDeSerializationSchemaTest.java → .../csv/CsvRowDeSerializationSchemaTest.java b/.../csv/CsvRowDeSerializationSchemaTest.java → .../csv/CsvRowDeSerializationSchemaTest.java