diff options
author | Rohit Rai <rohit@tuplejump.com> | 2013-06-02 12:51:15 +0530 |
---|---|---|
committer | Rohit Rai <rohit@tuplejump.com> | 2013-06-02 12:51:15 +0530 |
commit | 81c2adc15c9e232846d4ad0adf14d007039409fa (patch) | |
tree | 8751533e4ec2cf56affc7787d60d82353413285b /examples | |
parent | 3be7bdcefda13d67633f9b9f6d901722fd5649de (diff) | |
download | spark-81c2adc15c9e232846d4ad0adf14d007039409fa.tar.gz spark-81c2adc15c9e232846d4ad0adf14d007039409fa.tar.bz2 spark-81c2adc15c9e232846d4ad0adf14d007039409fa.zip |
Removing infix call
Diffstat (limited to 'examples')
-rw-r--r-- | examples/src/main/scala/spark/examples/CassandraTest.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/examples/src/main/scala/spark/examples/CassandraTest.scala b/examples/src/main/scala/spark/examples/CassandraTest.scala index 790b24e6f3..49b940d8a7 100644 --- a/examples/src/main/scala/spark/examples/CassandraTest.scala +++ b/examples/src/main/scala/spark/examples/CassandraTest.scala @@ -60,7 +60,7 @@ object CassandraTest { classOf[SortedMap[ByteBuffer, IColumn]]) // Let us first get all the paragraphs from the retrieved rows - val paraRdd = casRdd flatMap { + val paraRdd = casRdd.flatMap { case (key, value) => { value.filter(v => ByteBufferUtil.string(v._1).compareTo("para") == 0).map(v => ByteBufferUtil.string(v._2.value())) } @@ -69,8 +69,8 @@ object CassandraTest { //Lets get the word count in paras val counts = paraRdd.flatMap(p => p.split(" ")).map(word => (word, 1)).reduceByKey(_ + _) - counts.collect() foreach { - case(word, count) => println(word + ":" + count) + counts.collect().foreach { + case (word, count) => println(word + ":" + count) } } } |