Here is an example Pipeline which supports loading data from an unbounded source to BigQuery in batches using load jobs (evading BigQuery's Streaming Insert cost)
See: https://zero-master.github.io/posts/pub-sub-bigquery-beam/
See: https://zero-master.github.io/posts/pub-sub-bigquery-beam/