Wie erzwinge BigQueryIO.Write, um eine Tabelle in EU zu erstellen

Question

Ich führe eine Dataflow-Streaming-Pipeline. Währenddessen erstelle ich mehrere Tabellen, deren Namen sich während der Pipelineausführung ändern. Meine Dataflow-Pipeline wird in der EU ausgeführt. Ich habe folgende Einstellung Optionen hinzugefügt:

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

ich BigQueryIO.Write bin mit Daten speichern folgenden Code GBQ mit:

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

von diesem snipped erstellte Tabellen sind in der US gelegen. Wie kann ich erzwingen, BigQueryIO.Write Tabellen in der EU zu erstellen?

Answer 1

Obviusly ... Speicherort wird auf Datensatzebene festgelegt, nicht auf Tabellenebene. Daher sollte der Speicherort des Datasets, in dem die Tabelle erstellt wird, entsprechend angegeben werden.