apache/beam

Python SDK BigQuery `schemaUpdateOptions`

Aberta

#21.141 aberto em 4 de jun. de 2022

 (2 comentários) (0 reação) (1 responsável)Java (4.097 forks)batch import
P3gcpgood first issueimprovementiopythonusability

Métricas do repositório

Stars
 (7.313 estrelas)
Métricas de merge de PR
 (Métricas PR pendentes)

Description

I noticed that in the Java SDK schemaUpdateOptions are exposed clearly to the user: https://beam.apache.org/releases/javadoc/2.32.0/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.Write.html

 

Whereas, in the Python SDK this option seems to only be able to be passed through additional_bq_paramaters

 

Is this something which should be resolved? Perhaps add the schemaUpdateOptions to https://github.com/apache/beam/blob/b9457b711029051a837255e1bb516e55d32e56d5/sdks/python/apache_beam/io/gcp/bigquery.py#L437 and expose a kwarg to pass them in? 

Imported from Jira BEAM-12994. Original Jira may contain additional context. Reported by: judah.rand.

Guia do colaborador