Cloud Dataflow pipeline that reads the file from Cloud Storage and processes and outputs in the memory store.