shunping commented on code in PR #40794:
URL: https://github.com/apache/beam/pull/40794#discussion_r4373567336
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java:
##########
@@ -1948,6 +1955,27 @@ void cleanup(PassThroughThenCleanup.ContextContainer c)
throws Exception {
}
}
}
+
+ /**
+ * Returns the location the extract job ran in, which job lookups
must specify for
+ * regional locations: the source table's dataset location for
table reads, or the query
+ * location for query reads. A query read without an explicit
location returns null, as
+ * before; per {@link TypedRead#withQueryLocation}, that is only
supported for the US
+ * and EU multi-regions, where lookups work without a location.
+ */
+ private @Nullable String getExtractJobLocation(BigQueryOptions
bqOptions)
Review Comment:
Fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
