Quería aprovechar la nueva funcionalidad BigQuery de las tablas con particiones de tiempo, pero no estoy seguro de que esto sea posible actualmente en la versión 1.6 del SDK de Dataflow.

Mirando a laAPI BigQuery JSON, para crear una tabla particionada de día, uno debe pasar

"timePartitioning": { "type": "DAY" }

opción, pero la interfaz com.google.cloud.dataflow.sdk.io.BigQueryIO solo permite especificar una TableReference.

Pensé que tal vez podría precrear la tabla y escabullirme en un decorador de partición a través de un lambda BigQueryIO.Write.toTableReference. ¿Alguien más está teniendo éxito al crear / escribir tablas particionadas a través de Dataflow?

Esto parece un problema similar al configurar eltiempo de caducidad de la mesa que tampoco está disponible actualmente.