As an Apache Beam Python SDK developer, when wanting to write to BigQuery using its CDC capabilities, I would like to be able to configure what is the primary key of the table data will be written to and include the information of the row mutation to each record that will be written into the table.
Issue Priority
Priority: 2 (default / most feature requests should be filed as P2)
What would you like to happen?
As an Apache Beam Python SDK developer, when wanting to write to BigQuery using its CDC capabilities, I would like to be able to configure what is the primary key of the table data will be written to and include the information of the row mutation to each record that will be written into the table.
Issue Priority
Priority: 2 (default / most feature requests should be filed as P2)
Issue Components