[hudi] branch master updated: [HUDI-6731] BigQuerySyncTool: add flag to allow for read optimized sync for MoR tables (#9488)

[codope]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 21e462cca35 [HUDI-6731] BigQuerySyncTool: add flag to allow for read 
optimized sync for MoR tables (#9488)
21e462cca35 is described below

commit 21e462cca3551eaf84e10442cf7abd25003b40a8
Author: Tim Brown <t...@onehouse.ai>
AuthorDate: Tue Aug 22 01:48:59 2023 -0500

    [HUDI-6731] BigQuerySyncTool: add flag to allow for read optimized sync for 
MoR tables (#9488)
---
 .../main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java 
b/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java
index e0f5ace6c3a..47aa342dad0 100644
--- a/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java
+++ b/hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncTool.java
@@ -72,9 +72,9 @@ public class BigQuerySyncTool extends HoodieSyncTool {
     try (HoodieBigQuerySyncClient bqSyncClient = new 
HoodieBigQuerySyncClient(config)) {
       switch (bqSyncClient.getTableType()) {
         case COPY_ON_WRITE:
-          syncCoWTable(bqSyncClient);
-          break;
         case MERGE_ON_READ:
+          syncTable(bqSyncClient);
+          break;
         default:
           throw new UnsupportedOperationException(bqSyncClient.getTableType() 
+ " table type is not supported yet.");
       }
@@ -91,7 +91,7 @@ public class BigQuerySyncTool extends HoodieSyncTool {
     return false;
   }
 
-  private void syncCoWTable(HoodieBigQuerySyncClient bqSyncClient) {
+  private void syncTable(HoodieBigQuerySyncClient bqSyncClient) {
     ValidationUtils.checkState(bqSyncClient.getTableType() == 
HoodieTableType.COPY_ON_WRITE);
     LOG.info("Sync hoodie table " + snapshotViewName + " at base path " + 
bqSyncClient.getBasePath());