Details
-
Improvement
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Create table if needed is called once per destination per bundle. We should call it only once per destination at all. This can be done by passing the created tables as a side input.
https://github.com/apache/beam/blob/v2.13.0/sdks/python/apache_beam/io/gcp/bigquery.py#L804-L816