I have a file on Google Cloud Storage that contains a number of queries(insert/update/delete/select). I need to do two things: 1) execute all queries 2) for select queries write the result to a file in GCS.
What is the most efficient way to do this in Apache Beam?
Thank You.