def scioWithAlgebird()

in src/main/scala/com/spotify/bdrc/pipeline/CountUsers.scala [55:60]

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

  def scioWithAlgebird(input: SCollection[Rating]): SCollection[Long] = {
    import com.twitter.algebird.Aggregator.count
    input
      // Aggregate globally into a single `Long`
      .aggregate(count((_: Rating).user == "Smith"))
  }