apache_beam.io.gcp.bigquery_io_metadata module

Metadata for use in BigQueryIO, i.e. a job_id to use in BQ job labels.

apache_beam.io.gcp.bigquery_io_metadata.create_bigquery_io_metadata(step_name=None)[source]

Creates a BigQueryIOMetadata.

This will request metadata properly based on which runner is being used.

class apache_beam.io.gcp.bigquery_io_metadata.BigQueryIOMetadata(beam_job_id=None, step_name=None)[source]

Bases: object

Metadata class for BigQueryIO. i.e. to use as BQ job labels.

Do not construct directly, use the create_bigquery_io_metadata factory. Which will request metadata properly based on which runner is being used.

add_additional_bq_job_labels(job_labels=None)[source]