Is there any form to write to BigQuery specifying the name of destination tables dynamically?
Now I have:
bigQueryRQ
.apply(BigQueryIO.Write
.named("Write")
.to("project_name:dataset_name.table_name")
.withSchema(Table.create_auditedTableSchema())
.withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED)
.withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND));
But I need the "table_name" as a dynamic table name that depends on the "tablerow" data that I want to write.
Unfortunately, we don't provide an API to name the BigQuery table in a data-dependent way. Generally speaking, data-dependent BigQuery table destination(s) may be error prone.
That said, we are working on improving flexibility in this area. No estimates at this time, but we hope to get this soon.