如何强制 BigQueryIO.Write 在 EU 中创建 table

Question

我是运行 Dataflow 流式处理管道。在此期间，我创建了多个表，这些表的名称在管道执行期间发生了变化。我的数据流管道在欧盟运行。我在选项中添加了以下设置：

options.setZone("europe-west1-b");

我正在使用 BigQueryIO.Write 通过以下代码将数据保存到 GBQ：

BigQueryIO.Write
    .named(...)
    .to(DynamicTableName.of(...))
    .withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED)
    .withSchema(...)
    .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)

被截取的表格位于美国。我如何强制 BigQueryIO.Write 在 EU 中创建表？

Answer 1

显然...位置是在数据集级别设置的，而不是 table 级别。因此，应相应地指定创建 table 的数据集的位置。

如何强制 BigQueryIO.Write 在 EU 中创建 table

How to force BigQueryIO.Write to create table in EU

google-cloud-dataflow