scala - 如何在图中找到每个顶点的度-RDD转换？

val rdd1 = sc.parallelize(Seq((1,2),(1,3),(1,4),(2,3),(2,4),(3,4)))

边缘(Rdd1)通过创建。
我想找到图中每个顶点的度数。
我想向RDD1添加颠倒的订单。(2,1) (3,1) (4,1 ) (3,2) (4,2) (4,3)将被添加，以便
我可以通过每个键的值数找到顺序。
如何在rdd1的元素之间添加(y,x) to (x,y)？

最佳答案

rdd1.map(s=>((s._2,s._1),s))

((2,1),(1,2))
((4,2),(2,4))
((3,2),(2,3))
((3,1),(1,3))
((4,3),(3,4))
((4,1),(1,4))

关于scala - 如何在图中找到每个顶点的度-RDD转换？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/62575536/