### / - [BeamSqlInterpolatorWordCount.scala](BeamSqlInterpolatorWordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/BeamSqlInterpolatorWordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Minimal BeamSQL Word Count Example with interpolation - [BeamSqlWordCount.scala](BeamSqlWordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/BeamSqlWordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Minimal BeamSQL Word Count Example - [DebuggingWordCount.scala](DebuggingWordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/DebuggingWordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Word Count Example with Assertions - [MinimalWordCount.scala](MinimalWordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/MinimalWordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Minimal Word Count Example - [MinimalWordCountTypedArguments.scala](MinimalWordCountTypedArguments.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/MinimalWordCountTypedArguments.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Minimal Word Count Example - [WindowedWordCount.scala](WindowedWordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/WindowedWordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/WindowedWordCountTest.scala)) - Word Count Example with Windowing - [WordCount.scala](WordCount.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/WordCount.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Word Count Example with Metrics ### /complete/ - [AutoComplete.scala](AutoComplete.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/AutoComplete.scala)) - AutoComplete lines of text - [StreamingWordExtract.scala](StreamingWordExtract.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/StreamingWordExtract.scala)) - Streaming Word Extract - [TfIdf.scala](TfIdf.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/TfIdf.scala)) - Compute TF-IDF from a Text Corpus - [TopWikipediaSessions.scala](TopWikipediaSessions.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/TopWikipediaSessions.scala)) - Top Wikipedia Sessions - [TrafficMaxLaneFlow.scala](TrafficMaxLaneFlow.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/TrafficMaxLaneFlow.scala)) - Traffic max lane flow computation from sensor data - [TrafficRoutes.scala](TrafficRoutes.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/TrafficRoutes.scala)) - Traffic routes based on traffic sensor data ### /complete/game/ - [GameStats.scala](GameStats.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/GameStats.scala)) - Calculate game statistics: sum of team's scores, average user session length - [HourlyTeamScore.scala](HourlyTeamScore.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/HourlyTeamScore.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/HourlyTeamScoreTest.scala)) - Calculate the score for a team over a time window - [LeaderBoard.scala](LeaderBoard.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/LeaderBoard.scala)) - Calculate leaderboard for game (highest team scores, highest user scores) - [UserScore.scala](UserScore.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/UserScore.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/UserScoreTest.scala)) - Calculate the score for a user ### /cookbook/ - [BigQueryTornadoes.scala](BigQueryTornadoes.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/BigQueryTornadoes.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/BigQueryTornadoesTest.scala)) - BigQuery Tornadoes Example - [CombinePerKeyExamples.scala](CombinePerKeyExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/CombinePerKeyExamples.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/CombinePerKeyExamplesTest.scala)) - Combine Per Key Example - [DistinctByKeyExample.scala](DistinctByKeyExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/DistinctByKeyExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/DistinctByKeyExampleTest.scala)) - Distinct With RepresentativeValue Example - [DistinctExample.scala](DistinctExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/DistinctExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/DistinctExampleTest.scala)) - Distinct Example - [FilterExamples.scala](FilterExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/FilterExamples.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/FilterExamplesTest.scala)) - Filter Example - [JoinExamples.scala](JoinExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/JoinExamples.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/JoinExamplesTest.scala)) - Different Types of Joins - [MaxPerKeyExamples.scala](MaxPerKeyExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/MaxPerKeyExamples.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/MaxPerKeyExamplesTest.scala)) - Max Per Key Example - [StorageBigQueryTornadoes.scala](StorageBigQueryTornadoes.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/StorageBigQueryTornadoes.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/StorageBigQueryTornadoesTest.scala)) - Read using BigQuery Storage Read API. - [TriggerExample.scala](TriggerExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/TriggerExample.scala)) - Trigger example ### /extra/ - [AnnoyExamples.scala](AnnoyExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/AnnoyExamples.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/AnnoySideInputExampleTest.scala)) - Write a keyed SCollection as an Annoy file - [AvroExample.scala](AvroExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/AvroExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/AvroExampleTest.scala)) - Read and Write specific and generic Avro records - [AvroInOut.scala](AvroInOut.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/AvroInOut.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/AvroInOutTest.scala)) - Avro Input and Output - [BeamExample.scala](BeamExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/BeamExample.scala)) - Mix Beam Java SDK and Scio Code - [BigtableExample.scala](BigtableExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/BigtableExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/BigtableExampleTest.scala)) - Bigtable Input and Output - [CheckpointExample.scala](CheckpointExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/CheckpointExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/CheckpointExampleTest.scala)) - Use Checkpoints to debug a long workflow - [CloudSqlExample.scala](CloudSqlExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/CloudSqlExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/CloudSqlExampleTest.scala)) - Cloud SQL Input and Output - [DistCacheExample.scala](DistCacheExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/DistCacheExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/DistCacheExampleTest.scala)) - Distributed Cache Example - [DoFnExample.scala](DoFnExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/DoFnExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/DoFnExampleTest.scala)) - Mix Beam DoFn and Scio - [JavaConvertersExample.scala](JavaConvertersExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/JavaConvertersExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/JavaConvertersExampleTest.scala)) - Java converters for various output formats - [MetricsExample.scala](MetricsExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/MetricsExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/MetricsExampleTest.scala)) - Metrics Example - [ProtobufExample.scala](ProtobufExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ProtobufExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ProtobufExampleTest.scala)) - Protocol Buffer Input and Output - [RefreshingSideInputExample.scala](RefreshingSideInputExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/RefreshingSideInputExample.scala)) - Demonstrates a streaming job with periodically refreshing side input - [SafeFlatMapExample.scala](SafeFlatMapExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/SafeFlatMapExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/SafeFlatMapExampleTest.scala)) - SafeFlatMap usage - [ShapelessAvroExample.scala](ShapelessAvroExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ShapelessAvroExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ShapelessAvroExampleTest.scala)) - Shapeless Avro examples - [ShapelessDatastoreExample.scala](ShapelessDatastoreExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ShapelessDatastoreExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ShapelessDatastoreExampleTest.scala)) - Handling Datastore Types with Shapeless - [ShapelessTensorFlowExample.scala](ShapelessTensorFlowExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ShapelessTensorFlowExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ShapelessTensorFlowExampleTest.scala)) - Handling TensorFlow Example Types with Shapeless - [SideInOutExample.scala](SideInOutExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/SideInOutExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/SideInOutExampleTest.scala)) - Side Input and Output Example - [SingleGZipFileExample.scala](SingleGZipFileExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/SingleGZipFileExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/SingleGZipFileExampleTest.scala)) - Gzip File write - [StatefulExample.scala](StatefulExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/StatefulExample.scala)) - Stateful Processing - [TFExampleExample.scala](TFExampleExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TFExampleExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TFExampleExampleTest.scala)) - TensorFlow examples using shapeless-datatype - [TableRowJsonInOut.scala](TableRowJsonInOut.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TableRowJsonInOut.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TableRowJsonInOutTest.scala)) - BigQuery TableRow JSON Input and Output - [TapOutputExample.scala](TapOutputExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TapOutputExample.scala)) - Handling I/O with Tap - [TapsExample.scala](TapsExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TapsExample.scala)) - Use Futures and Taps to wait for resources - [TemplateExample.scala](TemplateExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TemplateExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TemplateExampleTest.scala)) - Pubsub Example using templates: - [TsvExample.scala](TsvExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TsvExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TsvExampleTest.scala)) - Reading and writing tsv data - [TypedBigQueryTornadoes.scala](TypedBigQueryTornadoes.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TypedBigQueryTornadoes.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TypedBigQueryTornadoesTest.scala)) - Read and write using typed BigQuery API with annotated case classes - [TypedStorageBigQueryTornadoes.scala](TypedStorageBigQueryTornadoes.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/TypedStorageBigQueryTornadoes.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/TypedStorageBigQueryTornadoesTest.scala)) - Read using typed BigQuery Storage API with annotated case classes - [WordCountOrchestration.scala](WordCountOrchestration.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/WordCountOrchestration.scala)) - Use Futures and Taps to orchestrate multiple jobs with dependencies - [WordCountScioIO.scala](WordCountScioIO.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/WordCountScioIO.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/WordCountScioIOTest.scala)) - Word Count Example with Metrics and ScioIO read/write - [WriteDynamicExample.scala](WriteDynamicExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/WriteDynamicExample.scala)) - Demonstrates saveAsDynamic* methods