def sparkApprox()

in src/main/scala/com/spotify/bdrc/pipeline/CountDistinctItems.scala [78:82]

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

  def sparkApprox(input: RDD[Rating]): Long = {
    input
      .map(_.item)
      .countApproxDistinct()
  }