examples/

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.

streaming_wordcap is a toy streaming pipeline that uses PubSub.

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.