def scaldingWithAlgebird()

in src/main/scala/com/spotify/bdrc/pipeline/Count.scala [39:44]

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

  def scaldingWithAlgebird(input: TypedPipe[Rating]): TypedPipe[Long] = {
    import com.twitter.algebird.Aggregator.size
    input
      .aggregate(size)
      .toTypedPipe
  }