Repository: beam Updated Branches: refs/heads/master 3b4e0fb16 -> 7057d1e22
Reopen BigQuery utils after #2271 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/077ee5ef Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/077ee5ef Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/077ee5ef Branch: refs/heads/master Commit: 077ee5efe7caf16354a3b9afbcc81f0a92abe248 Parents: 3b4e0fb Author: Rafal Wojdyla <[email protected]> Authored: Wed Mar 29 20:14:12 2017 -0400 Committer: Dan Halperin <[email protected]> Committed: Thu Mar 30 17:58:32 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/077ee5ef/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java index c5156e9..846103d 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java @@ -43,7 +43,7 @@ import org.apache.beam.sdk.transforms.SerializableFunction; /** * A set of helper functions and classes used by {@link BigQueryIO}. */ -class BigQueryHelpers { +public class BigQueryHelpers { private static final String RESOURCE_NOT_FOUND_ERROR = "BigQuery %1$s not found for table \"%2$s\" . Please create the %1$s before pipeline" + " execution. If the %1$s is created by an earlier stage of the pipeline, this" @@ -78,7 +78,7 @@ class BigQueryHelpers { /** * Returns a canonical string representation of the {@link TableReference}. */ - static String toTableSpec(TableReference ref) { + public static String toTableSpec(TableReference ref) { StringBuilder sb = new StringBuilder(); if (ref.getProjectId() != null) { sb.append(ref.getProjectId()); @@ -104,7 +104,7 @@ class BigQueryHelpers { * * <p>If the project id is omitted, the default project id is used. */ - static TableReference parseTableSpec(String tableSpec) { + public static TableReference parseTableSpec(String tableSpec) { Matcher match = BigQueryIO.TABLE_SPEC.matcher(tableSpec); if (!match.matches()) { throw new IllegalArgumentException(
