com.spotify.bdrc.pipeline

• AverageScorePerItem.scala (source) - Compute Average Score per Item
• Count.scala (source) - Count Number of Items
• CountDistinctItems.scala (source) - Count Number of Distinct Items
• CountUsers.scala (source) - Count the Number of Items of a Given User
• DistinctItems.scala (source) - Compute Collection of Distinct Items
• FieldStatistics.scala (source) - Compute Basic Descriptive Statistics for Each Field
• InvertedIndex.scala (source) - Build Inverted Index
• JoinLogAndMetadata.scala (source) - Join Log and Metadata Datasets
• JoinLogs.scala (source) - Join Two Log Datasets and Compute Action Sequence
• MaxItemPerUser.scala (source) - Compute One Item with Max Score per User
• MinItemPerUser.scala (source) - Compute One Item with Min Score per User
• Sessions.scala (source) - Compute Session Duration and Number of Items from Log Data
• Statistics.scala (source) - Compute Basic Descriptive Statistics
• SumPerItem.scala (source) - Compute the Sum of Scores per Item
• TopItems.scala (source) - Compute Top K Items Globally
• TopItemsPerUser.scala (source) - Compute Top K Items Globally
• WordCount.scala (source) - Classic Word Count