diff options
author | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2012-08-30 15:37:49 -0700 |
---|---|---|
committer | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2012-08-30 21:43:00 -0700 |
commit | 38835325454ff3afe2d410583ead37314e1ff49c (patch) | |
tree | e142ee524ed7b53d81e3d62a590fd022e92e56d7 /examples/src/main | |
parent | 8f2bd399da77d42d5f547ffae4db000643889eb4 (diff) | |
download | spark-38835325454ff3afe2d410583ead37314e1ff49c.tar.gz spark-38835325454ff3afe2d410583ead37314e1ff49c.tar.bz2 spark-38835325454ff3afe2d410583ead37314e1ff49c.zip |
Bug fix. Fixed log messages. Updated BroadcastTest example to have iterations.
Diffstat (limited to 'examples/src/main')
-rw-r--r-- | examples/src/main/scala/spark/examples/BroadcastTest.scala | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/examples/src/main/scala/spark/examples/BroadcastTest.scala b/examples/src/main/scala/spark/examples/BroadcastTest.scala index 4a560131e3..21de82cd87 100644 --- a/examples/src/main/scala/spark/examples/BroadcastTest.scala +++ b/examples/src/main/scala/spark/examples/BroadcastTest.scala @@ -17,9 +17,13 @@ object BroadcastTest { for (i <- 0 until arr1.length) arr1(i) = i - val barr1 = spark.broadcast(arr1) - spark.parallelize(1 to 10, slices).foreach { - i => println(barr1.value.size) + for (i <- 0 until 2) { + println("Iteration " + i) + println("===========") + val barr1 = spark.broadcast(arr1) + spark.parallelize(1 to 10, slices).foreach { + i => println(barr1.value.size) + } } System.exit(0) |