This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 1ff0a7f2eb195bb99ee84513653c18983eabeb68 Author: Tim Brown <[email protected]> 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());
