def main()

in src/main/scala/com/aliyun/emr/example/spark/SparkPi.scala [24:34]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  def main(args: Array[String]) {
    val slices = if (args.length > 0) args(0).toInt else 2
    val n = math.min(100000L * slices, Int.MaxValue).toInt // avoid overflow
    val count = getSparkContext.parallelize(1 until n, slices).map { i =>
        val x = random * 2 - 1
        val y = random * 2 - 1
        if (x*x + y*y < 1) 1 else 0
      }.reduce(_ + _)
    println("Pi is roughly " + 4.0 * count / n)
    getSparkContext.stop()
  }