2016-12-07 49 views
0

我运行一个数据流流管道创建表。在此期间,我创建了多个表,这些表在流水线执行期间名称正在改变。我的Dataflow管道在欧盟运行。我已经添加了以下设置选项:如何强制BigQueryIO.Write欧盟

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

我使用BigQueryIO.Write保存数据使用下面的代码吉贝:由文档片断创建

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

表位于美国。我如何强制BigQueryIO.Write在欧盟创建表格?

回答

1

Obviusly ...位置上设置数据集的水平,而不是表级别。因此应该相应地指定创建表的数据集的位置。