From 1739d57c59cfb6b90ccf3fcc9c07d1449fc17238 Mon Sep 17 00:00:00 2001 From: David Rabinowitz Date: Wed, 25 Nov 2020 06:26:53 -0800 Subject: [PATCH] fix: update listPartitions() to support tables from other projects (#974) * fix: update listPartitions() to support tables from other projects * code format Co-authored-by: yoshi-code-bot <70984784+yoshi-code-bot@users.noreply.github.com> Co-authored-by: yoshi-code-bot <70984784+yoshi-code-bot@users.noreply.github.com> --- .../main/java/com/google/cloud/bigquery/BigQueryImpl.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java b/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java index 0ed1ca68c..d402ce549 100644 --- a/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java +++ b/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java @@ -848,8 +848,12 @@ public Page listRoutines(DatasetId datasetId, RoutineListOption... opti @Override public List listPartitions(TableId tableId) { List partitions = new ArrayList(); - Table metaTable = - getTable(TableId.of(tableId.getDataset(), tableId.getTable() + "$__PARTITIONS_SUMMARY__")); + String partitionsTable = tableId.getTable() + "$__PARTITIONS_SUMMARY__"; + TableId metaTableId = + tableId.getProject() == null + ? TableId.of(tableId.getDataset(), partitionsTable) + : TableId.of(tableId.getProject(), tableId.getDataset(), partitionsTable); + Table metaTable = getTable(metaTableId); Schema metaSchema = metaTable.getDefinition().getSchema(); String partition_id = null; for (Field field : metaSchema.getFields()) {