Ingest data directly from Google BigQuery into Elastic using Google Dataflow