首页 > 其他 > 详细

spark实例2--sparkPi

时间:2015-08-09 18:22:46      阅读:334      评论:0      收藏:0      [点我收藏+]

代码:

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

spark实例2--sparkPi

原文:http://www.cnblogs.com/360Spark/p/4715414.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!