如何解决在beam.io.writetobigquery中使用架构更新选项
我正在使用Apache Beam数据流将一堆日志文件加载到BigQuery中。通过向文件添加新列，文件格式可以在一段时间内更改。我看到架构更新选项ALLOW_FILED_ADDITION。
任何人都知道如何使用它，这就是我的WritetoBQ步骤的样子。
| 'write to bigquery' >> beam.io.WritetoBigQuery('project:datasetId.tableId',write_disposition=beam.io.BigQuerydisposition.WRITE_APPEND)
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
