graphX ​​kann nicht mehrere Kanten und Scheitelpunkte grafisch darstellen?

Question

my vertice Typ ist:

org.apache.spark.rdd.RDD[((Long, String), (Long, String), (Long, String))]

my Kantentyp ist:

org.apache.spark.rdd.RDD[(org.apache.spark.graphx.Edge[String],org.apache.spark.graphx.Edge[String])]

Als ich versuchte zu Graph (Ecken, Kanten).

Es ist zu sagen:

<console>:47: error: type mismatch; 
found : org.apache.spark.rdd.RDD[((Long, String), (Long, String), (Long, String))] 
required: org.apache.spark.rdd.RDD[(org.apache.spark.graphx.VertexId, ?)] 

<console>:47: error: type mismatch; 
found : org.apache.spark.rdd.RDD[(org.apache.spark.graphx.Edge[String], org.apache.spark.graphx.Edge[String])] 
required: org.apache.spark.rdd.RDD[org.apache.spark.graphx.Edge[?]] 

(Lange String) tuple2 ist.

Answer 1

Ich denke, Sie müssen sowohl Ihre Ecke und Kante rdd korrigieren.

Vertex rdd es ist ein rdd [(VertexId, vertexValueType)]

so müssen Sie Ihren Scheitel rdd ändern:

rdd

org.apache.spark.rdd.RDD[(VertexId, ((Long, String), (Long, String), (Long, String)))] 

und Rand es ein rdd ist [Rand [edgeValueType] ] so in der Tat sollte es so sein:

org.apache.spark.rdd.RDD[org.apache.spark.graphx.Edge[String]] 

Vielleicht einen Code, den Sie veröffentlichen können, wo Sie diese RDDs tatsächlich schaffen?