Skip to content

[SPARK-16214] [Examples] fix the denominator of SparkPi #13910

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
yanghaogn wants to merge 3 commits into from
Closed

[SPARK-16214] [Examples] fix the denominator of SparkPi #13910

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
f91e55e
make rdd count be n
yanghaogn Jun 26, 2016
87ecf4d
avoid overflow
yanghaogn Jun 26, 2016
1cfbea2
Update SparkPi.scala
yanghaogn Jun 26, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
make rdd count be n
  • Loading branch information
@yanghaogn
yanghaogn authored Jun 26, 2016
commit f91e55eb6a9c81189292989a40d9a4e76dc9309c
2 changes: 1 addition & 1 deletion examples/src/main/scala/org/apache/spark/examples/SparkPi.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ object SparkPi {
.getOrCreate()
val slices = if (args.length > 0) args(0).toInt else 2
val n = math.min(100000L * slices, Int.MaxValue).toInt // avoid overflow
val count = spark.sparkContext.parallelize(1 until n, slices).map { i =>
val count = spark.sparkContext.parallelize(1 to n, slices).map { i =>
val x = random * 2 - 1
val y = random * 2 - 1
if (x*x + y*y < 1) 1 else 0
Expand Down