[Hotfix][JDBC/Connector] Correct the annotations be right

Author: RocMarshal

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java

@@ -17,7 +17,7 @@
 
 package org.apache.flink.connector.jdbc.datasource.connections;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.connector.jdbc.JdbcConnectionOptions;
 import org.apache.flink.util.Preconditions;
 
@@ -37,7 +37,7 @@
 
 /** Simple JDBC connection provider. */
 @NotThreadSafe
-@PublicEvolving
+@Experimental
 public class SimpleJdbcConnectionProvider implements JdbcConnectionProvider, Serializable {
 
     private static final Logger LOG = LoggerFactory.getLogger(SimpleJdbcConnectionProvider.class);

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.connector.source.Boundedness;
@@ -51,7 +51,7 @@
 import java.util.Objects;
 
 /** JDBC source. */
-@PublicEvolving
+@Experimental
 public class JdbcSource<OUT>
         implements Source<OUT, JdbcSourceSplit, JdbcSourceEnumeratorState>,
                 ResultTypeQueryable<OUT> {

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.connector.base.DeliveryGuarantee;
@@ -95,7 +95,7 @@
  * @see DriverManager
  * @see JdbcSource
  */
-@PublicEvolving
+@Experimental
 public class JdbcSourceBuilder<OUT> {
 
     public static final Logger LOG = LoggerFactory.getLogger(JdbcSourceBuilder.class);

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceOptions.java

@@ -18,13 +18,15 @@
 
 package org.apache.flink.connector.jdbc.source;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.ConfigOptions;
 
 import java.io.Serializable;
 import java.sql.ResultSet;
 
 /** JDBC source options. */
+@Experimental
 public class JdbcSourceOptions implements Serializable {
 
     private JdbcSourceOptions() {}

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumStateSerializer.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.enumerator;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplitSerializer;
 import org.apache.flink.core.io.SimpleVersionedSerializer;
@@ -36,6 +37,7 @@
 import static org.apache.flink.util.Preconditions.checkArgument;
 
 /** The serializer for {@link JdbcSourceEnumeratorState}. */
+@Experimental
 public class JdbcSourceEnumStateSerializer
         implements SimpleVersionedSerializer<JdbcSourceEnumeratorState>, Serializable {
 

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumerator.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.enumerator;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.connector.source.Boundedness;
 import org.apache.flink.api.connector.source.SourceEvent;
 import org.apache.flink.api.connector.source.SplitEnumerator;
@@ -42,6 +43,7 @@
 import java.util.Optional;
 
 /** JDBC source enumerator. */
+@Experimental
 public class JdbcSourceEnumerator
         implements SplitEnumerator<JdbcSourceSplit, JdbcSourceEnumeratorState> {
     private static final Logger LOG = LoggerFactory.getLogger(JdbcSourceEnumerator.class);

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.enumerator;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
 import org.apache.flink.util.Preconditions;
 
@@ -30,7 +30,7 @@
 import java.util.Objects;
 
 /** Enumerator state class for {@link JdbcSourceEnumerator}. */
-@PublicEvolving
+@Experimental
 public class JdbcSourceEnumeratorState implements Serializable {
 
     private final @Nonnull List<JdbcSourceSplit> completedSplits;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.enumerator;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
 
 import javax.annotation.Nonnull;
@@ -34,7 +34,7 @@
  *
  * @param <SplitT> JDBC split type.
  */
-@PublicEvolving
+@Experimental
 public abstract class JdbcSqlSplitEnumeratorBase<SplitT> implements AutoCloseable, Serializable {
     private final char[] currentId = "0000000000".toCharArray();
 
@@ -78,7 +78,7 @@ public abstract List<JdbcSourceSplit> enumerateSplits(@Nonnull Supplier<Boolean>
      *
      * @param <SplitT> Split type.
      */
-    @PublicEvolving
+    @Experimental
     public interface Provider<SplitT> extends Serializable {
 
         /**

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/SqlTemplateSplitEnumerator.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.enumerator;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.connector.jdbc.source.split.CheckpointedOffset;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
@@ -38,6 +39,7 @@
 import java.util.function.Supplier;
 
 /** A split enumerator based on sql-parameters grains. */
+@Experimental
 public final class SqlTemplateSplitEnumerator extends JdbcSqlSplitEnumeratorBase<JdbcSourceSplit> {
 
     public static final Logger LOG = LoggerFactory.getLogger(SqlTemplateSplitEnumerator.class);

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcRecordEmitter.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.reader;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.connector.source.SourceOutput;
 import org.apache.flink.connector.base.source.reader.RecordEmitter;
 import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
@@ -29,6 +30,7 @@
  * @param <T> The type of the record.
  * @param <SplitT> The type of JDBC split.
  */
+@Experimental
 public class JdbcRecordEmitter<T, SplitT extends JdbcSourceSplit>
         implements RecordEmitter<RecordAndOffset<T>, T, JdbcSourceSplitState<SplitT>> {
 

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceReader.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.reader;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.connector.source.SourceReaderContext;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase;
@@ -33,6 +34,7 @@
  *
  * @param <OUT> The type of the record readed from the source.
  */
+@Experimental
 public class JdbcSourceReader<OUT>
         extends SingleThreadMultiplexSourceReaderBase<
                 RecordAndOffset<OUT>, OUT, JdbcSourceSplit, JdbcSourceSplitState<JdbcSourceSplit>> {

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceSplitReader.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.reader;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.connector.source.SourceReaderContext;
@@ -62,6 +63,7 @@
  *
  * @param <T> The type of the record read from the source.
  */
+@Experimental
 public class JdbcSourceSplitReader<T>
         implements SplitReader<RecordAndOffset<T>, JdbcSourceSplit>, ResultTypeQueryable<T> {
 

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/RecordAndOffset.java

@@ -18,13 +18,15 @@
 
 package org.apache.flink.connector.jdbc.source.reader;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.connector.jdbc.source.split.CheckpointedOffset;
 
 /**
  * Util class to represent the record with the corresponding information.
  *
  * @param <E> The type of the record.
  */
+@Experimental
 public class RecordAndOffset<E> {
 
     public static final long NO_OFFSET = CheckpointedOffset.NO_OFFSET;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.reader.extractor;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.types.Row;
 
 import java.io.Serializable;
@@ -30,7 +30,7 @@
  *
  * @param <T> The target data type.
  */
-@PublicEvolving
+@Experimental
 public interface ResultExtractor<T> extends Serializable {
 
     /**

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/RowResultExtractor.java

@@ -18,13 +18,15 @@
 
 package org.apache.flink.connector.jdbc.source.reader.extractor;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.types.Row;
 import org.apache.flink.util.Preconditions;
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
 /** The extractor is used to extract the data from {@link ResultSet} into a {@link Row} object. */
+@Experimental
 public class RowResultExtractor implements ResultExtractor<Row> {
     @Override
     public Row extract(ResultSet resultSet) throws SQLException {

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/CheckpointedOffset.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.split;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 
 import java.io.Serializable;
 import java.util.Objects;
@@ -27,7 +27,7 @@
  * The class to hold the offset for checkpointed state. Note: The current class is not enabled for
  * using.
  */
-@PublicEvolving
+@Experimental
 public class CheckpointedOffset implements Serializable {
 
     public static final int NO_OFFSET = 0;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java

@@ -18,7 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.split;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.connector.source.SourceSplit;
 import org.apache.flink.util.Preconditions;
 
@@ -30,7 +30,7 @@
 import java.util.Optional;
 
 /** JdbcSourceSplit class. */
-@PublicEvolving
+@Experimental
 public class JdbcSourceSplit implements SourceSplit, Serializable {
 
     private final String id;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplitSerializer.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.split;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.core.io.SimpleVersionedSerializer;
 import org.apache.flink.util.InstantiationUtil;
 
@@ -31,6 +32,7 @@
 import static org.apache.flink.util.Preconditions.checkArgument;
 
 /** The class is used to de/serialize the {@link JdbcSourceSplit}. */
+@Experimental
 public class JdbcSourceSplitSerializer implements SimpleVersionedSerializer<JdbcSourceSplit> {
 
     private static final int CURRENT_VERSION = 0;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplitState.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.source.split;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.util.FlinkRuntimeException;
 
 import java.io.Serializable;
@@ -26,6 +27,7 @@
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 /** The class is hold the state information of {@link JdbcSourceSplit}. */
+@Experimental
 public class JdbcSourceSplitState<SplitT extends JdbcSourceSplit> implements Serializable {
 
     private final SplitT split;

flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcSlideTimingParameterProvider.java

@@ -18,6 +18,7 @@
 
 package org.apache.flink.connector.jdbc.split;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.util.Preconditions;
 
 import javax.annotation.Nonnull;
@@ -27,6 +28,7 @@
 import java.util.List;
 
 /** The parameters provider generate parameters by slide timing window strategy. */
+@Experimental
 public class JdbcSlideTimingParameterProvider implements JdbcParameterValuesProvider {
 
     private final long slideStepMills;