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