def spark()

in src/main/scala/com/spotify/bdrc/pipeline/Count.scala [58:62]

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

  def spark(input: RDD[Rating]): Long = {
    input
      // `count` is an action and collects data back to the driver node
      .count
  }