Как заставить BigQueryIO.Write создать таблицу в ЕС

Question

Я запускаю потоковый потоковый конвейер. Во время этого я создаю несколько таблиц, имена которых меняются во время выполнения конвейера. Мой трубопровод Dataflow работает в ЕС. Я добавил следующие настройки для опций:

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 создавать таблицы в ЕС?

Answer 1

Объект Obviusly ... установлен на уровне набора данных, а не на уровне таблицы. Таким образом, должно быть указано расположение набора данных, в котором создается таблица.