removed unnecessary flink internal annotations and added copied infor…

…mation in every copied class
PeterZh6 · Nov 25, 2024 · b0cf263 · b0cf263
1 parent 6d46470
commit b0cf263
Show file tree

Hide file tree

Showing 14 changed files with 18 additions and 26 deletions.
diff --git a/.../sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java b/.../sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java
@@ -83,10 +83,9 @@
  * <p>See {@link KafkaSourceBuilder} for more details on how to configure this source.
  *
  * @param <OUT> the output type of the source.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 // TODO: Add a variable metricSchema to report audit information
-@PublicEvolving
 public class KafkaSource<OUT>
         implements
             Source<OUT, KafkaPartitionSplit, KafkaSourceEnumState>,
@@ -137,7 +136,6 @@ public Boundedness getBoundedness() {
         return this.boundedness;
     }
 
-    @Internal
     @Override
     public SourceReader<OUT, KafkaPartitionSplit> createReader(SourceReaderContext readerContext)
             throws Exception {
@@ -187,7 +185,7 @@ public UserCodeClassLoader getUserCodeClassLoader() {
                 kafkaSourceReaderMetrics);
     }
 
-    @Internal
+
     @Override
     public SplitEnumerator<KafkaPartitionSplit, KafkaSourceEnumState> createEnumerator(
             SplitEnumeratorContext<KafkaPartitionSplit> enumContext) {
@@ -200,7 +198,7 @@ public SplitEnumerator<KafkaPartitionSplit, KafkaSourceEnumState> createEnumerat
                 boundedness);
     }
 
-    @Internal
+
     @Override
     public SplitEnumerator<KafkaPartitionSplit, KafkaSourceEnumState> restoreEnumerator(
             SplitEnumeratorContext<KafkaPartitionSplit> enumContext,
@@ -216,13 +214,13 @@ public SplitEnumerator<KafkaPartitionSplit, KafkaSourceEnumState> restoreEnumera
                 checkpoint);
     }
 
-    @Internal
+
     @Override
     public SimpleVersionedSerializer<KafkaPartitionSplit> getSplitSerializer() {
         return new KafkaPartitionSplitSerializer();
     }
 
-    @Internal
+
     @Override
     public SimpleVersionedSerializer<KafkaSourceEnumState> getEnumeratorCheckpointSerializer() {
         return new KafkaSourceEnumStateSerializer();

diff --git a/...onnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSourceBuilder.java b/...onnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSourceBuilder.java
@@ -86,10 +86,9 @@
  *
  * <p>Check the Java docs of each individual methods to learn more about the settings to build a
  * KafkaSource.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 // TODO: Add a variable metricSchema to report audit information
-@PublicEvolving
 public class KafkaSourceBuilder<OUT> {
 
     private static final Logger LOG = LoggerFactory.getLogger(KafkaSourceBuilder.class);

diff --git a/...ors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java b/...ors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java
@@ -46,10 +46,9 @@
 import java.util.concurrent.ConcurrentMap;
 
 /** The source reader for Kafka partitions.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 // TODO: Add some method to make report audit information exactly once
-@Internal
 public class KafkaSourceReader<T>
         extends
             SingleThreadMultiplexSourceReaderBase<ConsumerRecord<byte[], byte[]>, T, KafkaPartitionSplit, KafkaPartitionSplitState> {

diff --git a/...a/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java b/...a/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java
@@ -36,7 +36,7 @@
 import java.util.List;
 
 /** A specific {@link KafkaSerializationSchema} for {@link KafkaDynamicSource}.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 // TODO: support SourceExactlyMetric and add metric collection points
 class DynamicKafkaDeserializationSchema implements KafkaDeserializationSchema<RowData> {

diff --git a/...c/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaRecordSerializationSchema.java b/...c/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaRecordSerializationSchema.java
@@ -32,7 +32,7 @@
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 /** SerializationSchema used by {@link KafkaDynamicSink} to configure a {@link KafkaSink}.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 class DynamicKafkaRecordSerializationSchema implements KafkaRecordSerializationSchema<RowData> {
 

diff --git a/...nectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptions.java b/...nectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptions.java
@@ -34,9 +34,8 @@
 
 /**
  * Options for the Kafka connector.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
-@PublicEvolving
 public class KafkaConnectorOptions {
 
     // --------------------------------------------------------------------------------------------

diff --git a/...ors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptionsUtil.java b/...ors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptionsUtil.java
@@ -72,9 +72,8 @@
 import static org.apache.flink.table.factories.FactoryUtil.FORMAT;
 
 /** Utilities for {@link KafkaConnectorOptions}.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
-@Internal
 class KafkaConnectorOptionsUtil {
 
     private static final ConfigOption<String> SCHEMA_REGISTRY_SUBJECT =

diff --git a/...t-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSink.java b/...t-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSink.java
@@ -63,8 +63,8 @@
 
 /**
  * A version-agnostic Kafka {@link DynamicTableSink}.
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
-@Internal
 public class KafkaDynamicSink implements DynamicTableSink, SupportsWritingMetadata {
 
     private static final String UPSERT_KAFKA_TRANSFORMATION = "upsert-kafka";

diff --git a/...connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java b/...connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java
@@ -77,9 +77,8 @@
 
 /**
  * A version-agnostic Kafka {@link ScanTableSource}.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * org.apache.flink:flink-connector-kafka:3.2.0
  */
-@Internal
 public class KafkaDynamicSource
         implements
             ScanTableSource,

diff --git a/...tors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java b/...tors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java
@@ -99,9 +99,8 @@
 /**
  * Factory for creating configured instances of {@link KafkaDynamicSource} and {@link
  * KafkaDynamicSink}.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * org.apache.flink:flink-connector-kafka:3.2.0
  */
-@Internal
 public class KafkaDynamicTableFactory
         implements
             DynamicTableSourceFactory,

diff --git a/...connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/ReducingUpsertSink.java b/...connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/ReducingUpsertSink.java
@@ -36,7 +36,7 @@
  * <p>The sink provides eventual consistency guarantees under {@link
  * org.apache.flink.connector.base.DeliveryGuarantee#AT_LEAST_ONCE} because the updates are
  * idempotent therefore duplicates have no effect.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 class ReducingUpsertSink<WriterState, Comm>
         implements

diff --git a/...nnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/ReducingUpsertWriter.java b/...nnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/ReducingUpsertWriter.java
@@ -41,7 +41,7 @@
 import static org.apache.inlong.sort.kafka.table.DynamicKafkaRecordSerializationSchema.createProjectedRow;
 
 /**
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 class ReducingUpsertWriter<WriterState, Comm>
         implements

diff --git a/...onnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/SinkBufferFlushMode.java b/...onnectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/SinkBufferFlushMode.java
@@ -21,7 +21,7 @@
 import java.util.Objects;
 
 /** Sink buffer flush configuration.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 public class SinkBufferFlushMode implements Serializable {
 

diff --git a/...afka/src/main/java/org/apache/inlong/sort/kafka/table/UpsertKafkaDynamicTableFactory.java b/...afka/src/main/java/org/apache/inlong/sort/kafka/table/UpsertKafkaDynamicTableFactory.java
@@ -82,7 +82,7 @@
 
 /**
  * Upsert-Kafka factory.
- * copied from org.apache.flink:flink-connector-kafka:1.18.0
+ * copied from org.apache.flink:flink-connector-kafka:3.2.0
  */
 public class UpsertKafkaDynamicTableFactory
         implements