DataflowJavaSDK
DataflowJavaSDK copied to clipboard
BigQuery: Support time partitioned tables
trafficstars
Right now BigQueryIO doesn't offer a way to specify that the tables, when created, should be marked as time partitioned.
Documentation: https://cloud.google.com/bigquery/docs/creating-partitioned-tables
What I would like is something like:
...
.apply(BigQueryIO.Write
.setTimePartitioning(TimePartitioning.Type.DAY)
.withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)
....