chamikaramj commented on a change in pull request #12082:
URL: https://github.com/apache/beam/pull/12082#discussion_r461967928
##########
File path:
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
##########
@@ -457,6 +456,22 @@
* </a> for security and permission related information specific to BigQuery.
*/
public class BigQueryIO {
+
+ /**
+ * Template for BigQuery jobs created by BigQueryIO. This template is: {@code
+ * "beam_bq_job_{TYPE}_{JOB_ID}_{STEP}_{RANDOM}"}, where:
+ *
+ * <ul>
+ * <li>{@code TYPE} represents the BigQuery job type (e.g. extract / copy
/ load / query)
+ * <li>{@code JOB_ID} is the Dataflow job name.
Review comment:
Nit: what if the runner is not Dataflow ?
##########
File path: sdks/python/apache_beam/io/gcp/bigquery.py
##########
@@ -290,6 +290,20 @@ def compute_table_name(row):
]
_LOGGER = logging.getLogger(__name__)
+"""
+Template for BigQuery jobs created by BigQueryIO. This template is:
+`"beam_bq_job_{job_type}_{job_id}_{step_id}_{random}"`, where:
+
+- `job_type` represents the BigQuery job type (e.g. extract / copy / load /
+ query).
+- `job_id` is the Dataflow job name.
Review comment:
Ditto.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
