examples/

directory
v2.7.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 26, 2018 License: Apache-2.0, BSD-3-Clause, MIT

Directories

Path Synopsis
complete
cookbook
max
tornadoes
tornadoes is an example that reads the public samples of weather data from BigQuery, counts the number of tornadoes that occur in each month, and writes the results to BigQuery.
tornadoes is an example that reads the public samples of weather data from BigQuery, counts the number of tornadoes that occur in each month, and writes the results to BigQuery.
debugging_wordcount is an example that verifies word counts in Shakespeare and includes Beam best practices.
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.
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.
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.
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.
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.
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.
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.
yatzy is an implementation of https://en.wikipedia.org/wiki/Yatzy that shows that pipeline construction is normal Go code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL