This directory holds code to build an Apache Beam pipeline written in go.
Run the following command to execute the pipeline on your local machine.
go run ./cmd --source=testdata/catsum.txt --output=/tmp/wordcount/catsum
or
Assumes previously run gcloud auth application-default login
go run ./cmd --source=gs://apache-beam-samples/shakespeare/* output=/tmp/wordcount/shakespeare