Apache Beam/Google Cloud Dataflow job that copies Firestore in Datastore mode entities matching a query from one db to another - View it on GitHub