examples/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Directories ¶

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

Path	Synopsis
complete
autocomplete
contains
cookbook
combine
filter
join
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 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 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.
grades
minimal_wordcount minimal_wordcount is an example that counts words in Shakespeare.	minimal_wordcount is an example that counts words in Shakespeare.
multiout 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.
pingpong
readavro 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	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 streaming_wordcap is a toy streaming pipeline that uses PubSub.	streaming_wordcap is a toy streaming pipeline that uses PubSub.
stringsplit An example of using a Splittable DoFn in the Go SDK with a portable runner.	An example of using a Splittable DoFn in the Go SDK with a portable runner.
windowed_wordcount 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 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.
xlang
cogroup_by cogroup_by exemplifies using a cross-language cogroup by key transform from a test expansion service.	cogroup_by exemplifies using a cross-language cogroup by key transform from a test expansion service.
combine combine exemplifies using a cross-language combine per key transform from a test expansion service.	combine exemplifies using a cross-language combine per key transform from a test expansion service.
combine_globally combine_globally exemplifies using a cross-language combine global transform from a test expansion service.	combine_globally exemplifies using a cross-language combine global transform from a test expansion service.
flatten
group_by group_by exemplifies using a cross-language group by key transform from a test expansion service.	group_by exemplifies using a cross-language group by key transform from a test expansion service.
multi_input_output multi exemplifies using a cross-language transform with multiple inputs and outputs from a test expansion service.	multi exemplifies using a cross-language transform with multiple inputs and outputs from a test expansion service.
partition partition exemplifies using a cross-language partition transform from a test expansion service.	partition exemplifies using a cross-language partition transform from a test expansion service.
wordcount wordcount exemplifies using a cross-language Count transform from a test expansion service to count words.	wordcount exemplifies using a cross-language Count transform from a test expansion service to count words.
yatzy 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.