Skip to content Skip to sidebar Skip to footer
Showing posts with the label Dataflow

How To Filter None Values Out Of Pcollection

My pubsub pull subscription is sending over the message and a None value for each message. I need t… Read more How To Filter None Values Out Of Pcollection

ValueError: A BigQuery Table Or A Query Must Be Specified With Beam.io.gcp.bigquery.ReadFromBigQuery

I'm trying to pass a BigQuery table name as a value provider for a apache beam pipeline templat… Read more ValueError: A BigQuery Table Or A Query Must Be Specified With Beam.io.gcp.bigquery.ReadFromBigQuery