Using BigQuery Storage Write API in Beam pipelines.

Source