prodriguezdefino commented on code in PR #32529:
URL: https://github.com/apache/beam/pull/32529#discussion_r1777924046
##########
sdks/python/apache_beam/io/gcp/bigquery.py:
##########
@@ -2086,6 +2087,12 @@ def __init__(
GCP expansion service. Used for STORAGE_WRITE_API method.
max_insert_payload_size: The maximum byte size for a BigQuery legacy
streaming insert payload.
+ cdc_writes_with_primary_key: Configure the usage of CDC writes on
BigQuery
+ and sets the primary key using the column names from the argument.
+ The destination table (or tables if using dynamic destionations) will
+ be created in case of using CREATE_IF_NEEDED mode, and StorageWrite API
+ at least once mode will be configured. Used for STORAGE_WRITE_API
+ method.
Review Comment:
done.
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
