directory
2.59.0
Repository: https://github.com/leocbs/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.
No description provided by the author
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
taxi is an example using a cross-language Kafka pipeline to write and read to Kafka.
large_wordcount is an example that demonstrates a more complex version of a wordcount pipeline.
minimal_wordcount is an example that counts words in King Lear, by William Shakespeare.
multiout is a wordcount variation that uses a multi-outout DoFn and writes 2 output files.
native_wordcap is a toy streaming pipeline that uses PubSub.
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.
slowly_updating_side_input is an example pipeline demonstrating the pattern described at https://beam.apache.org/documentation/patterns/side-inputs/.
Package snippets contains code used in the Beam Programming Guide as examples for the Apache Beam Go SDK.
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.
timer_wordcap is a toy streaming pipeline that demonstrates the use of State and Timers.
wasm is a simple example that loads and executes a wasm file function.
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 demonstrates Beam best practices.
Package xlang contains functionality for testing cross-language transforms.
yatzy is an implementation of https://en.wikipedia.org/wiki/Yatzy that shows that pipeline construction is normal Go code.