examples/

directory
Version: v2.34.0-RC1 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2021 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.
taxi is an example using a cross-language Kafka pipeline to write and read to Kafka.
taxi is an example using a cross-language Kafka pipeline to write and read to Kafka.
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.
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
Package snippets contains code used in the Beam Programming Guide as examples for the Apache Beam Go SDK.
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.
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.
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.
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.
Package xlang contains functionality for testing cross-language transforms.
Package xlang contains functionality for testing cross-language transforms.
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.
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 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