Use BQ Storage Write API for integration tests infrastructure

[mkuthan]

BigQueryClient utility for integration tests uses Streaming Insert API.

stream-processing/stream-processing-test/src/main/scala/org/mkuthan/streamprocessing/test/gcp/BigQueryClient.scala

Line 163 in 83336c3

def writeTable(datasetName: String, tableName: String, records: TableRow*): Unit = {

• Rewrite BigQueryClient.writeTable from Streaming Insert into Storage Write API.