directory
2.24.0+incompatible
Repository: https://github.com/amustafa/beam.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
No description provided by the author
No description provided by the author
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.
No description provided by the author
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.
No description provided by the author
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.