### com.spotify.bdrc.pipeline - [AverageScorePerItem.scala](AverageScorePerItem.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/AverageScorePerItem.scala)) - Compute Average Score per Item - [Count.scala](Count.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/Count.scala)) - Count Number of Items - [CountDistinctItems.scala](CountDistinctItems.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/CountDistinctItems.scala)) - Count Number of Distinct Items - [CountUsers.scala](CountUsers.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/CountUsers.scala)) - Count the Number of Items of a Given User - [DistinctItems.scala](DistinctItems.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/DistinctItems.scala)) - Compute Collection of Distinct Items - [FieldStatistics.scala](FieldStatistics.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/FieldStatistics.scala)) - Compute Basic Descriptive Statistics for Each Field - [InvertedIndex.scala](InvertedIndex.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/InvertedIndex.scala)) - Build Inverted Index - [JoinLogAndMetadata.scala](JoinLogAndMetadata.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/JoinLogAndMetadata.scala)) - Join Log and Metadata Datasets - [JoinLogs.scala](JoinLogs.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/JoinLogs.scala)) - Join Two Log Datasets and Compute Action Sequence - [MaxItemPerUser.scala](MaxItemPerUser.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/MaxItemPerUser.scala)) - Compute One Item with Max Score per User - [MinItemPerUser.scala](MinItemPerUser.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/MinItemPerUser.scala)) - Compute One Item with Min Score per User - [Sessions.scala](Sessions.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/Sessions.scala)) - Compute Session Duration and Number of Items from Log Data - [Statistics.scala](Statistics.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/Statistics.scala)) - Compute Basic Descriptive Statistics - [SumPerItem.scala](SumPerItem.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/SumPerItem.scala)) - Compute the Sum of Scores per Item - [TopItems.scala](TopItems.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/TopItems.scala)) - Compute Top K Items Globally - [TopItemsPerUser.scala](TopItemsPerUser.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/TopItemsPerUser.scala)) - Compute Top K Items Globally - [WordCount.scala](WordCount.scala.html) ([source](https://github.com/spotify/big-data-rosetta-code/blob/master/src/main/scala/com/spotify/bdrc/pipeline/WordCount.scala)) - Classic Word Count