2017-02-24 67 views

回答

1
val nums = sc.parallelize((0 to 4)).flatMap(x => { 
    (x to 4).filter(_ > x).map((x, _)) 
}) 

println(nums.collect().toList) 
//List((0,1), (0,2), (0,3), (0,4), (1,2), (1,3), (1,4), (2,3), (2,4), (3,4))