[beam] branch master updated: [BEAM-10822] Fixed typo in BigqueryClient

[pa...@apache.org]

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

pabloem 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 0efc4f3  [BEAM-10822] Fixed typo in BigqueryClient
     new 11aa4a0  Merge pull request #15559 from [BEAM-10822] Fixed typo in BigqueryClient
0efc4f3 is described below

commit 0efc4f3562ea839038f89c0547e31c0ee678f4c0
Author: Alexander Chermenin <al...@team.wrike.com>
AuthorDate: Thu Sep 23 12:02:16 2021 +0500

    [BEAM-10822] Fixed typo in BigqueryClient
---
 .../java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java     | 6 +++---
 .../sdk/io/gcp/bigquery/BigQueryTimePartitioningClusteringIT.java   | 4 ++--
 .../java/org/apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java
index ad9bc6a..3ec6285 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java
@@ -78,7 +78,7 @@ import org.slf4j.LoggerFactory;
  * <p>Get a new Bigquery client:
  *
  * <pre>{@code [
- *    BigqueryClient client = BigqueryClient.getNewBigquerryClient(applicationName);
+ *    BigqueryClient client = BigqueryClient.getNewBigqueryClient(applicationName);
  * ]}</pre>
  *
  * <p>Execute a query with retries:
@@ -149,7 +149,7 @@ public class BigqueryClient {
     return credential;
   }
 
-  public static Bigquery getNewBigquerryClient(String applicationName) {
+  public static Bigquery getNewBigqueryClient(String applicationName) {
     HttpTransport transport = Transport.getTransport();
     JsonFactory jsonFactory = Transport.getJsonFactory();
     Credentials credential = getDefaultCredential();
@@ -163,7 +163,7 @@ public class BigqueryClient {
   }
 
   public BigqueryClient(String applicationName) {
-    bqClient = BigqueryClient.getNewBigquerryClient(applicationName);
+    bqClient = BigqueryClient.getNewBigqueryClient(applicationName);
   }
 
   @Nonnull
diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTimePartitioningClusteringIT.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTimePartitioningClusteringIT.java
index c0e5bf7..7e94551 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTimePartitioningClusteringIT.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTimePartitioningClusteringIT.java
@@ -69,7 +69,7 @@ public class BigQueryTimePartitioningClusteringIT {
     PipelineOptionsFactory.register(BigQueryClusteringITOptions.class);
     options = TestPipeline.testingPipelineOptions().as(BigQueryClusteringITOptions.class);
     options.setTempLocation(options.getTempRoot() + "/temp-it/");
-    bqClient = BigqueryClient.getNewBigquerryClient(options.getAppName());
+    bqClient = BigqueryClient.getNewBigqueryClient(options.getAppName());
   }
 
   /** Customized PipelineOptions for BigQueryClustering Integration Test. */
@@ -143,7 +143,7 @@ public class BigQueryTimePartitioningClusteringIT {
 
     p.run().waitUntilFinish();
 
-    bqClient = BigqueryClient.getNewBigquerryClient(options.getAppName());
+    bqClient = BigqueryClient.getNewBigqueryClient(options.getAppName());
     Table table = bqClient.tables().get(options.getProject(), DATASET_NAME, tableName).execute();
 
     Assert.assertEquals(table.getTimePartitioning(), TIME_PARTITIONING);
diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java
index da8f944..66e7e6a 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java
@@ -58,7 +58,7 @@ public class BigqueryClientTest {
     when(mockBigqueryClient.jobs()).thenReturn(mockJobs);
     when(mockJobs.query(anyString(), any(QueryRequest.class))).thenReturn(mockQuery);
     PowerMockito.mockStatic(BigqueryClient.class);
-    when(BigqueryClient.getNewBigquerryClient(anyString())).thenReturn(mockBigqueryClient);
+    when(BigqueryClient.getNewBigqueryClient(anyString())).thenReturn(mockBigqueryClient);
     bqClient = spy(new BigqueryClient("test-app"));
   }