Skip to content

Commit

Permalink
Removing experimental annotation from JdbcIO
Browse files Browse the repository at this point in the history
  • Loading branch information
pabloem committed Jul 22, 2022
1 parent de5c56a commit 68ff1c7
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,6 @@
import java.util.stream.Collectors;
import java.util.stream.IntStream;
import javax.sql.DataSource;
import org.apache.beam.sdk.annotations.Experimental;
import org.apache.beam.sdk.annotations.Experimental.Kind;
import org.apache.beam.sdk.coders.CannotProvideCoderException;
import org.apache.beam.sdk.coders.Coder;
import org.apache.beam.sdk.coders.CoderRegistry;
Expand Down Expand Up @@ -305,7 +303,6 @@
* Consider using <a href="https://en.wikipedia.org/wiki/Merge_(SQL)">MERGE ("upsert")
* statements</a> supported by your database instead.
*/
@Experimental(Kind.SOURCE_SINK)
@SuppressWarnings({
"rawtypes", // TODO(https://github.com/apache/beam/issues/20447)
"nullness" // TODO(https://github.com/apache/beam/issues/20497)
Expand All @@ -327,7 +324,6 @@ public static <T> Read<T> read() {
}

/** Read Beam {@link Row}s from a JDBC data source. */
@Experimental(Kind.SCHEMAS)
public static ReadRows readRows() {
return new AutoValue_JdbcIO_ReadRows.Builder()
.setFetchSize(DEFAULT_FETCH_SIZE)
Expand Down Expand Up @@ -594,7 +590,6 @@ public interface StatementPreparator extends Serializable {

/** Implementation of {@link #readRows()}. */
@AutoValue
@Experimental(Kind.SCHEMAS)
public abstract static class ReadRows extends PTransform<PBegin, PCollection<Row>> {

abstract @Nullable SerializableFunction<Void, DataSource> getDataSourceProviderFn();
Expand Down

0 comments on commit 68ff1c7

Please sign in to comment.