Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val b = sc.parallelize(Array(1,2,3))
- val c: Int = 4
- def add (x:org.apache.spark.rdd.RDD[Int]) = { x.map( n => n + c) }
- add(b).collect()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement