在 Apache Beam 中为 BigQueryIO 指定架构更新选项

Question

是否可以在 Apache Beam 中为 BigQueryIO 指定架构选项？ Afaik 通常可以使用com.google.api.services.bigquery.model.JobConfigurationLoad 指定在将新字段插入表时应该更新架构：

JobConfigurationLoad loadConfig = new JobConfigurationLoad();
..
loadConfig.setSchemaUpdateOptions(Arrays.asList("ALLOW_FIELD_ADDITION", "ALLOW_FIELD_RELAXATION"));

但是如何使用 Apache Beam 中的 BigQueryIO 类来指定它？我正在使用 Apache Beam SDK 2.1.0。

Answer 1

Beam 目前不支持此功能。已经为此提交了a feature request。它应该很容易实现（欢迎贡献:)），但我认为现在没有人积极致力于它。