Присоединиться к более чем vertexrdd[double] graphx scala

Мне нужно присоединиться более чем к 2 VertexRDD[Double].

Я пытаюсь это с помощью следующего кода, но не могу заставить его работать

val vertices=Array((1L, 11.0),(2L, 12.3),(3L,13.8)) 
val vRDD= sc.parallelize(vertices) 

val edges = Array(Edge(1L,2L,1800.0),Edge(2L,3L,800.0),Edge(3L,1L,1400.0)) 
val eRDD= sc.parallelize(edges)  

val vertices2=Array((1L, 1.0),(2L, 2.3),(3L,3.8)) 
val vRDD2= sc.parallelize(vertices2) 

val edges2 = Array(Edge(1L,2L,1800.0),Edge(2L,3L,800.0),Edge(3L,1L,1400.0)) 
val eRDD2= sc.parallelize(edges2)  

val vertices3=Array((1L, 21.0),(2L, 22.3),(3L,23.8)) 
val vRDD3= sc.parallelize(vertices3) 

val edges3 = Array(Edge(1L,2L,1800.0),Edge(2L,3L,800.0),Edge(3L,1L,1400.0)) 
val eRDD3= sc.parallelize(edges3) 

val g1 = Graph(vRDD,eRDD) 
val g2 = Graph(vRDD2,eRDD2) 
val g3 = Graph(vRDD3,eRDD3) 

//val vset3 = g1.vertices.join(g2.vertices)  
//val vset4 = vset3.join(g2.vertices)  
val vset3 = g1.vertices.leftZipJoin(g2.vertices) { (vid, a, b) => a+","+b }

вывод здесь:

1 11.0 1.0 21.0
2 12.3 2.3 22.3
3 13.8 3.8 23.8

0 ответов

Другие вопросы по тегам