def scio()

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

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

  def scio(input: SCollection[Rating]): SCollection[Long] = {
    input
      .map(_.item)
      .distinct
      .count
  }