You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2019/01/24 22:29:06 UTC

[beam] branch master updated: make getCurrentSchemaPlus public

This is an automated email from the ASF dual-hosted git repository.

anton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new e5e66bf  make getCurrentSchemaPlus public
     new b1603ce  Merge pull request #7609 from amaliujia/rui_wang-make_getschema_public
e5e66bf is described below

commit e5e66bfa3967049d43853bc29005f6197a5d3324
Author: amaliujia <am...@gmail.com>
AuthorDate: Wed Jan 23 13:25:17 2019 -0800

    make getCurrentSchemaPlus public
---
 .../java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java
index e3c2aa6..1955ec6 100644
--- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java
+++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java
@@ -108,7 +108,7 @@ public class JdbcConnection extends CalciteConnectionWrapper {
   }
 
   /** Calcite-created {@link SchemaPlus} wrapper for the current schema. */
-  SchemaPlus getCurrentSchemaPlus() {
+  public SchemaPlus getCurrentSchemaPlus() {
     try {
       return getRootSchema().getSubSchema(getSchema());
     } catch (SQLException e) {