debugging_wordcount is an example that verifies word counts in Shakespeare and includes Beam best practices.

forest is an example that shows that pipeline construction is normal Go code -- the pipeline "forest" is created recursively and uses a global variable -- and that a pipeline may contain non-connected parts.

minimal_wordcount is an example that counts words in Shakespeare.

multiout is a wordcount variation that uses a multi-outout DoFn and writes 2 output files.

readavro is a simple Avro read/write Example This example uses a 500 Byte sample avro file [twitter.avro] download here: https://s3-eu-west-1.amazonaws.com/daidokoro-dev/apache/twitter.avro.

streaming_wordcap is a toy streaming pipeline that uses PubSub.

An example of using a Splittable DoFn in the Go SDK with a portable runner.

windowed_wordcount counts words in text, and can run over either unbounded or bounded input collections.

wordcount is an example that counts words in Shakespeare and includes Beam best practices.

yatzy is an implementation of https://en.wikipedia.org/wiki/Yatzy that shows that pipeline construction is normal Go code.