Updating access modifiers for utility methods (#28511)

* Updating access modifiers for utility methods * Revert "Updating access modifiers for utility methods" This reverts commit 99eb926. * Updating access modifiers for utility methods
apache · Sep 19, 2023 · 272da41 · 272da41
1 parent 0f72792
commit 272da41
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
@@ -786,7 +786,7 @@ public PCollection<Row> expand(PBegin input) {
 
     // Spotbugs seems to not understand the multi-statement try-with-resources
     @SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION")
-    private static Schema inferBeamSchema(DataSource ds, String query) {
+    public static Schema inferBeamSchema(DataSource ds, String query) {
       try (Connection conn = ds.getConnection();
           PreparedStatement statement =
               conn.prepareStatement(

diff --git a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java
@@ -354,7 +354,7 @@ private static ResultSetFieldExtractor createObjectExtractor() {
    * A {@link org.apache.beam.sdk.io.jdbc.JdbcIO.RowMapper} implementation that converts JDBC
    * results into Beam {@link Row} objects.
    */
-  static final class BeamRowMapper implements JdbcIO.RowMapper<Row> {
+  public static final class BeamRowMapper implements JdbcIO.RowMapper<Row> {
     private final Schema schema;
     private final List<ResultSetFieldExtractor> fieldExtractors;