def sparkWithAlgebird()

in src/main/scala/com/spotify/bdrc/pipeline/AverageScorePerItem.scala [81:91]

• 9 lines of code
• 1 McCabe index (conditional complexity)

  def sparkWithAlgebird(input: RDD[Rating]): RDD[(String, Double)] = {
    import com.twitter.algebird.AveragedValue
    import com.twitter.algebird.spark._
    input
      .keyBy(_.user)
      .mapValues(_.score)
      // Map values into `Double`
      .algebird
      // Aggregate average per key
      .aggregateByKey(AveragedValue.aggregator)
  }