Re: 答复: 答复: it does not stop at breakpoints which is in an anonymous function

2016-09-23 Thread Dirceu Semighini Filho
val x = random * 2 - 1 (breakpoint-1) > val y = random * 2 - 1 > if (x*x + y*y < 1) 1 else 0 > }.reduce(_ + _) > println("Pi is roughly " + 4.0 * count / (n - 1)) > spark.stop() > } > } > > > > > --------

答复: 答复: it does not stop at breakpoints which is in an anonymous function

2016-09-18 Thread chen yong
lho <dirceu.semigh...@gmail.com> 发送时间: 2016年9月16日 22:27 收件人: chen yong 抄送: user@spark.apache.org 主题: Re: 答复: it does not stop at breakpoints which is in an anonymous function No, that's not the right way of doing it. Remember that RDD operations are lazy, due to performance reasons. Whenever