代码：

import org.apache.spark.SparkConf

import org.apache.spark.SparkContext

import scala.math.random

object SparkPi {

  def main(args:Array[String]){

    val conf=new SparkConf().setAppName("SparkPi").setMaster("local")

    val sc=new SparkContext(conf)

    val num=500000;

    val numRdd=sc.parallelize(1 to num)

    val  count= numRdd.map{

      n=>{

        val x=random*2-1

        val y=random*2-1

        if(x*x+y*y<1)

          1

          else

            0

      }

    }.reduce(_+_)

    println(4.0*count/num)

  }

}

原理：

这个是利用概率求圆周率

边长为1的正方形里有一个内接圆，半径为1/2,任意取一个点（x,y）（0=<x<1,0=<y<1）落入圆内的概率

p=圆的面积/正方形的面积=（pi/4）

经过多次取随即点，此随机点到圆心(1/2,1/2)的距离小于1/2则在园内

sqrt((x-1/2）*(x-1/2)+(y-1/2)*(y-1/2))<1/2

化简后

(2x-1)*(2x-1)+(2y-1)*(2y-1)<1

如果次数多的话，随即点落入园内的次数（count）/取的总次数（num） =上面的p

所以

count/num=pi/4

pi=4*count/pi