spark计算圆周率

spark可以用来计算圆周率。通过生成随机点，并判断这些点是否在一个单位圆内，最后根据落入圆中点的比例来估计圆周率的值。下面是一个使用spark计算圆周率的示例代码：

import org.apache.spark.{SparkContext, SparkConf}
import scala.math.random

object SparkPai {
  def main(args: Array[String]) {
    val conf = new SparkConf().setAppName("SparkPai").setMaster("local[4]")
    val sc = new SparkContext(conf)
    
    val slices = if (args.length > 0) args(0).toInt else 2
    val n = math.min(10000L * slices, Int.MaxValue).toInt
    
    val count = sc.parallelize(1 until n, slices).map { _ =>
      val x = random * 2 - 1
      val y = random * 2 - 1
      
      if (x * x + y * y < 1) 1 else 0
    }.reduce(_ + _)
    
    val pi = 4.0 * count / n
    
    println("Pi is roughly " + pi)
    
    sc.stop()
  }
}