Tag: apache beam

在Apache Beam中向不同的BigQuery表写入不同的值

假设我有一个PCollection<Foo> ,我想把它写到多个BigQuery表中,为每个Fooselect一个可能不同的表。 我怎样才能使用Apache Beam BigQueryIO API来做到这一点?