Advertisement
Guest User

Untitled

a guest
Jul 31st, 2015
203
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.34 KB | None | 0 0
  1. scala> val input = sc.parallelize(List(1, 2, 4, 1881824400))
  2. input: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[0] at parallelize at <console>:21
  3.  
  4. scala> val result = input.map(x => 2*x)
  5. result: org.apache.spark.rdd.RDD[Int] = MapPartitionsRDD[1] at map at <console>:23
  6.  
  7. scala> println(result.collect().mkString(","))
  8. 2,4,8,-531318496
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement