def scalding()

in src/main/scala/com/spotify/bdrc/pipeline/Statistics.scala [57:66]

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

  def scalding(input: TypedPipe[Rating]): TypedPipe[Stats] =
    input.aggregate(aggregator)

  // ## Scio
  def scio(input: SCollection[Rating]): SCollection[Stats] = {
    input
      .map(_.score)
      .stats
      .map(s => Stats(s.max, s.min, s.sum, s.count, s.mean, s.stdev))
  }