From 0291729827c3fc88b913f161374473ede61cb6a0 Mon Sep 17 00:00:00 2001 From: Rafal Wojdyla Date: Wed, 29 Mar 2017 20:14:12 -0400 Subject: [PATCH] Reopen BigQuery utils after #2271 --- .../apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 c5156e9e7830..846103da8ea6 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 @@ /** * 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 @@ static ValueProvider displayTable( /** * 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 @@ static List getOrCreateMapListValue(Map> map, K key) { * *

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(