def sparkAlgebird()

in src/main/scala/com/spotify/bdrc/pipeline/Statistics.scala [79:82]

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

  def sparkAlgebird(input: RDD[Rating]): Stats = {
    import com.twitter.algebird.spark._
    input.algebird.aggregate(aggregator)
  }