Apache Beam Bigquery Example Python