Writing an ETL pipeline using Apache Beam and Cloud Dataflow (Java)