Advertisement
Guest User

Untitled

a guest
Feb 9th, 2016
42
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.21 KB | None | 0 0
  1. val a = List((3, 1.0), (2, 2.0), (4, 2.0), (1,0.0))
  2. val rdd = sc.parallelize(a)
  3.  
  4. val b = ((rdd.takeOrdered(2).zipWithIndex.map{case (k,v) => (v,k)}).toList find {x => x._1 == 1}).map(x => x._2).map(x=> x._1)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement