def scioAlgebird()

in src/main/scala/com/spotify/bdrc/pipeline/Statistics.scala [69:76]

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

  def scioAlgebird(input: SCollection[Rating]): SCollection[Stats] =
    input.aggregate(aggregator)

  // ## Spark
  def spark(input: RDD[Rating]): Stats = {
    val s = input.map(_.score).stats()
    Stats(s.max, s.min, s.sum, s.count, s.mean, s.stdev)
  }