Advertisement
Guest User

Untitled

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