### / - [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 - [MinimalWordCountPipelineOptionsExample.scala](MinimalWordCountPipelineOptionsExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/MinimalWordCountPipelineOptionsExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala)) - Minimal Word Count Examples with typed arguments - [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 - [BinaryInOut.scala](BinaryInOut.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/BinaryInOut.scala)) - Binary Input and Output - [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 - [ElasticsearchMinimalExample.scala](ElasticsearchMinimalExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ElasticsearchMinimalExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ElasticsearchMinimalExampleTest.scala)) - Elasticsearch minimal example - [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 - [MagnolifyAvroExample.scala](MagnolifyAvroExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyAvroExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyAvroExampleTest.scala)) - Handling Avro GenericRecord Types with Magnolify - [MagnolifyBigtableExample.scala](MagnolifyBigtableExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyBigtableExample.scala)) - Handling Bigtable Mutations and Rows with Magnolify - [MagnolifyDatastoreExample.scala](MagnolifyDatastoreExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyDatastoreExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyDatastoreExampleTest.scala)) - Handling Datastore Entity Types with Magnolify - [MagnolifyTensorFlowExample.scala](MagnolifyTensorFlowExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyTensorFlowExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyTensorFlowExampleTest.scala)) - Handling TensorFlow Example Types with Magnolify - [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 - [Neo4JExample.scala](Neo4JExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/Neo4JExample.scala)) - Neo4J Input and Output (requires a running Neo4J instance with data) - [ParquetExample.scala](ParquetExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/ParquetExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/ParquetExampleTest.scala)) - Read and write Parquet in Avro and Typed formats - [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 - [RedisExamples.scala](RedisExamples.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/RedisExamples.scala)) - Redis Examples - [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 - [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 - [SortMergeBucketExample.scala](SortMergeBucketExample.scala.html) ([source](https://github.com/spotify/scio/blob/master/scio-examples/src/main/scala/com/spotify/scio/examples/extra/SortMergeBucketExample.scala), [test](https://github.com/spotify/scio/blob/master/scio-examples/src/test/scala/com/spotify/scio/examples/extra/SortMergeBucketExampleTest.scala)) - Sort Merge Bucket write and join - [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 - [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