Advertisement
Guest User

Untitled

a guest
Mar 29th, 2017
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.44 KB | None | 0 0
  1. scala> val numbers = sc.parallelize(10 to 50 by 10)
  2. numbers: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[9] at parallelize at <console>:24
  3.  
  4. scala> numbers.collect().foreach(println)
  5. 10
  6. 20
  7. 30
  8. 40
  9. 50
  10.  
  11. scala> numbers.foreach(x => println(x))
  12.  
  13. scala>
  14.  
  15. Spark version 2.0.0.cloudera2
  16. Using Scala version 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_111)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement