This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 2defbbcf [FLINK-35496] Revert "[FLINK-35496] Fix annotations on new
JdbcSink and JdbcSource"
2defbbcf is described below
commit 2defbbcf4fc550a76dd9c664e1eed7d261e028ca
Author: Roc Marshal <[email protected]>
AuthorDate: Tue Jun 4 11:48:47 2024 +0800
[FLINK-35496] Revert "[FLINK-35496] Fix annotations on new JdbcSink and
JdbcSource"
This reverts commit b955e8b5479c65512f94ee7270eb2868a4a14ebe.
---
.../src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java | 2 --
.../jdbc/datasource/connections/JdbcConnectionProvider.java | 4 ++--
.../jdbc/datasource/connections/SimpleJdbcConnectionProvider.java | 4 ++--
.../jdbc/datasource/connections/xa/XaConnectionProvider.java | 4 ++--
.../connector/jdbc/datasource/statements/JdbcQueryStatement.java | 4 ++--
.../jdbc/datasource/statements/SimpleJdbcQueryStatement.java | 4 ++--
.../transactions/xa/exceptions/EmptyTransactionXaException.java | 4 ++--
.../datasource/transactions/xa/exceptions/TransientXaException.java | 4 ++--
.../main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java | 4 ++--
.../java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java | 4 ++--
.../java/org/apache/flink/connector/jdbc/source/JdbcSource.java | 4 ++--
.../org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java | 4 ++--
.../connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java | 4 ++--
.../jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java | 6 +++---
.../connector/jdbc/source/reader/extractor/ResultExtractor.java | 4 ++--
.../flink/connector/jdbc/source/split/CheckpointedOffset.java | 4 ++--
.../apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java | 4 ++--
.../connector/jdbc/split/JdbcGenericParameterValuesProvider.java | 4 ++--
.../connector/jdbc/split/JdbcNumericBetweenParametersProvider.java | 2 --
.../flink/connector/jdbc/split/JdbcParameterValuesProvider.java | 4 ++--
20 files changed, 37 insertions(+), 41 deletions(-)
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java
index 1cee1a09..efd976e2 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java
@@ -17,7 +17,6 @@
package org.apache.flink.connector.jdbc;
-import org.apache.flink.annotation.Experimental;
import org.apache.flink.annotation.PublicEvolving;
import
org.apache.flink.connector.jdbc.datasource.connections.SimpleJdbcConnectionProvider;
import org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction;
@@ -109,7 +108,6 @@ public class JdbcSink {
exactlyOnceOptions);
}
- @Experimental
public static <IN> JdbcSinkBuilder<IN> builder() {
return org.apache.flink.connector.jdbc.sink.JdbcSink.builder();
}
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java
index 76dfe5a2..81c6bccb 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java
@@ -17,7 +17,7 @@
package org.apache.flink.connector.jdbc.datasource.connections;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
@@ -28,7 +28,7 @@ import java.sql.SQLException;
import java.util.Properties;
/** JDBC connection provider. */
-@Experimental
+@PublicEvolving
public interface JdbcConnectionProvider extends Serializable, AutoCloseable {
/**
* Get existing connection.
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java
index b533bc19..811210af 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.JdbcConnectionOptions;
import org.apache.flink.util.Preconditions;
@@ -37,7 +37,7 @@ import java.util.Properties;
/** Simple JDBC connection provider. */
@NotThreadSafe
-@Experimental
+@PublicEvolving
public class SimpleJdbcConnectionProvider implements JdbcConnectionProvider,
Serializable {
private static final Logger LOG =
LoggerFactory.getLogger(SimpleJdbcConnectionProvider.class);
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java
index 54e8c39d..5f0b5a2e 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java
@@ -1,6 +1,6 @@
package org.apache.flink.connector.jdbc.datasource.connections.xa;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider;
import
org.apache.flink.connector.jdbc.datasource.transactions.xa.exceptions.TransientXaException;
@@ -25,7 +25,7 @@ import java.util.Collection;
*
* {@link #recover} can be used to get abandoned prepared transactions for
cleanup.
*/
-@Experimental
+@PublicEvolving
public interface XaConnectionProvider extends JdbcConnectionProvider {
void open() throws Exception;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
index e75e066c..13638046 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
@@ -17,7 +17,7 @@
package org.apache.flink.connector.jdbc.datasource.statements;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import java.io.Serializable;
import java.sql.PreparedStatement;
@@ -26,7 +26,7 @@ import java.sql.SQLException;
/**
* Sets {@link PreparedStatement} parameters to use in JDBC Sink based on a
specific type of record.
*/
-@Experimental
+@PublicEvolving
public interface JdbcQueryStatement<T> extends Serializable {
String query();
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java
index 86675c78..ea295f4c 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java
@@ -17,14 +17,14 @@
package org.apache.flink.connector.jdbc.datasource.statements;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.JdbcStatementBuilder;
import java.sql.PreparedStatement;
import java.sql.SQLException;
/** A simple implementation for {@link JdbcQueryStatement}. */
-@Experimental
+@PublicEvolving
public class SimpleJdbcQueryStatement<IN> implements JdbcQueryStatement<IN> {
private final String query;
private final JdbcStatementBuilder<IN> statement;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java
index 86af9df9..ae3374a3 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java
@@ -1,6 +1,6 @@
package org.apache.flink.connector.jdbc.datasource.transactions.xa.exceptions;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.xa.XaFacade;
import org.apache.flink.util.FlinkRuntimeException;
@@ -12,7 +12,7 @@ import javax.transaction.xa.Xid;
* XA_RDONLY} indicating that the transaction doesn't include any changes.
When such a transaction
* is committed RM may return an error (usually, {@link XAException#XAER_NOTA
XAER_NOTA}).
*/
-@Experimental
+@PublicEvolving
public class EmptyTransactionXaException extends FlinkRuntimeException {
private final Xid xid;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java
index 0fe91097..b6b37a30 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java
@@ -1,6 +1,6 @@
package org.apache.flink.connector.jdbc.datasource.transactions.xa.exceptions;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.util.FlinkRuntimeException;
import javax.transaction.xa.XAException;
@@ -9,7 +9,7 @@ import javax.transaction.xa.XAException;
* Indicates a transient or unknown failure from the resource manager (see
{@link
* XAException#XA_RBTRANSIENT XA_RBTRANSIENT}, {@link XAException#XAER_RMFAIL
XAER_RMFAIL}).
*/
-@Experimental
+@PublicEvolving
public class TransientXaException extends FlinkRuntimeException {
public TransientXaException(XAException cause) {
super(cause);
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java
index d70313c5..986fcba1 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java
@@ -17,8 +17,8 @@
package org.apache.flink.connector.jdbc.sink;
-import org.apache.flink.annotation.Experimental;
import org.apache.flink.annotation.Internal;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.connector.sink2.Committer;
import org.apache.flink.api.connector.sink2.StatefulSink;
import org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink;
@@ -45,7 +45,7 @@ import java.util.Collections;
*
* @see JdbcSinkBuilder on how to construct a JdbcSink
*/
-@Experimental
+@PublicEvolving
public class JdbcSink<IN>
implements StatefulSink<IN, JdbcWriterState>,
TwoPhaseCommittingSink<IN, JdbcCommitable> {
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java
index 2716d456..ede9a00e 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java
@@ -17,7 +17,7 @@
package org.apache.flink.connector.jdbc.sink;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.base.DeliveryGuarantee;
import org.apache.flink.connector.jdbc.JdbcConnectionOptions;
import org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions;
@@ -37,7 +37,7 @@ import javax.sql.XADataSource;
import static org.apache.flink.util.Preconditions.checkNotNull;
/** Builder to construct {@link JdbcSink}. */
-@Experimental
+@PublicEvolving
public class JdbcSinkBuilder<IN> {
private JdbcExecutionOptions executionOptions;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java
index 40736488..fc145feb 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.annotation.VisibleForTesting;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.connector.source.Boundedness;
@@ -48,7 +48,7 @@ import java.util.ArrayList;
import java.util.Objects;
/** JDBC source. */
-@Experimental
+@PublicEvolving
public class JdbcSource<OUT>
implements Source<OUT, JdbcSourceSplit, JdbcSourceEnumeratorState>,
ResultTypeQueryable<OUT> {
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java
index 0de6bfe4..17e3eb27 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.connector.base.DeliveryGuarantee;
@@ -89,7 +89,7 @@ import static
org.apache.flink.connector.jdbc.source.JdbcSourceOptions.RESULTSET
* @see DriverManager
* @see JdbcSource
*/
-@Experimental
+@PublicEvolving
public class JdbcSourceBuilder<OUT> {
public static final Logger LOG =
LoggerFactory.getLogger(JdbcSourceBuilder.class);
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java
index 8cba4dec..2cd3903c 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
import org.apache.flink.util.Preconditions;
@@ -30,7 +30,7 @@ import java.util.List;
import java.util.Objects;
/** Enumerator state class for {@link JdbcSourceEnumerator}. */
-@Experimental
+@PublicEvolving
public class JdbcSourceEnumeratorState implements Serializable {
private final @Nonnull List<JdbcSourceSplit> completedSplits;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java
index 580402bc..7e0d70d1 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.source.split.JdbcSourceSplit;
import javax.annotation.Nullable;
@@ -32,7 +32,7 @@ import java.util.List;
*
* @param <SplitT> JDBC split type.
*/
-@Experimental
+@PublicEvolving
public abstract class JdbcSqlSplitEnumeratorBase<SplitT> implements
AutoCloseable, Serializable {
private final char[] currentId = "0000000000".toCharArray();
@@ -74,7 +74,7 @@ public abstract class JdbcSqlSplitEnumeratorBase<SplitT>
implements AutoCloseabl
*
* @param <SplitT> Split type.
*/
- @Experimental
+ @PublicEvolving
public interface Provider<SplitT> extends Serializable {
/**
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java
index 1a649169..19bd6672 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.types.Row;
import java.io.Serializable;
@@ -30,7 +30,7 @@ import java.sql.SQLException;
*
* @param <T> The target data type.
*/
-@Experimental
+@PublicEvolving
public interface ResultExtractor<T> extends Serializable {
/**
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/CheckpointedOffset.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/CheckpointedOffset.java
index 3c851cf3..e6fa7572 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/CheckpointedOffset.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import java.io.Serializable;
import java.util.Objects;
@@ -27,7 +27,7 @@ import java.util.Objects;
* The class to hold the offset for checkpointed state. Note: The current
class is not enabled for
* using.
*/
-@Experimental
+@PublicEvolving
public class CheckpointedOffset implements Serializable {
public static final int NO_OFFSET = 0;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java
index 584fff03..af71a58a 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java
+++
b/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.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.connector.source.SourceSplit;
import javax.annotation.Nullable;
@@ -29,7 +29,7 @@ import java.util.Objects;
import java.util.Optional;
/** JdbcSourceSplit class. */
-@Experimental
+@PublicEvolving
public class JdbcSourceSplit implements SourceSplit, Serializable {
private final String id;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
index e406ce47..d9637982 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
@@ -18,7 +18,7 @@
package org.apache.flink.connector.jdbc.split;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.JdbcInputFormat;
import java.io.Serializable;
@@ -27,7 +27,7 @@ import java.io.Serializable;
* This splits generator actually does nothing but wrapping the query
parameters computed by the
* user before creating the {@link JdbcInputFormat} instance.
*/
-@Experimental
+@PublicEvolving
public class JdbcGenericParameterValuesProvider implements
JdbcParameterValuesProvider {
private final Serializable[][] parameters;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
index e6f92178..617e6c52 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
@@ -18,7 +18,6 @@
package org.apache.flink.connector.jdbc.split;
-import org.apache.flink.annotation.Experimental;
import org.apache.flink.util.Preconditions;
import java.io.Serializable;
@@ -38,7 +37,6 @@ import java.io.Serializable;
* <p>You can take advantage of this class to automatically generate the
parameters of the BETWEEN
* clause, based on the passed constructor parameters.
*/
-@Experimental
public class JdbcNumericBetweenParametersProvider implements
JdbcParameterValuesProvider {
private final long minVal;
diff --git
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
index b3e67206..8dcceb28 100644
---
a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
+++
b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
@@ -18,7 +18,7 @@
package org.apache.flink.connector.jdbc.split;
-import org.apache.flink.annotation.Experimental;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.jdbc.JdbcInputFormat;
import java.io.Serializable;
@@ -28,7 +28,7 @@ import java.io.Serializable;
* run (i.e. splits). Each query will be parameterized using a row of the
matrix provided by each
* {@link JdbcParameterValuesProvider} implementation.
*/
-@Experimental
+@PublicEvolving
public interface JdbcParameterValuesProvider extends Serializable {
/** Returns the necessary parameters array to use for query in parallel a
table. */
