2016-04-08 14 views
-1

benim tepelerinin türüdür:graphX, birden çok Kenar ve Merkez grafiği çizemiyor?

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

zaman kenar türüdür:

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

I (özet olarak, kenarlar) grafik üzerinde çalıştığında.

O söylüyor:

<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[?]] 

(Uzun String) tuple2 olduğunu.

+1

Ne demek istiyorsun ((Uzun, Dize), (Uzun, Dize), (Uzun, Dize))? Öğeler olarak üç tuple sahip bir “RDD” yi mi, yoksa “RDD” deki her satırın 3 tuplesinin olduğunu mu düşünüyorsunuz? –

cevap

0

Hem köşe hem de kenar rdd'yi düzeltmeniz gerektiğini düşünüyorum.

köşe RDD o

böylece için köşe RDD değiştirmek zorunda bir RDD [(VertexId, vertexValueType)]: bir RDD olduğunu

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

ve kenar RDD [Kenar [edgeValueType] ] yüzden gerçekten böyle olmalıdır:

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

Belki de aslında bu rdds oluşturmak bir kod gönderebilir?