2016-04-08 11 views
-1

私の頂点タイプがある:graphXは複数のエッジと頂点をグラフ化できませんか?

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

私のエッジタイプがある:

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

Iは(頂​​点、エッジ)をグラフ化しようとしたとき。

それは言っている:

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

(長い文字列)がtuple2です。

+1

あなたは、((ロング、ストリング)、(ロング、ストリング)、(ロング、ストリング))という意味はどう思いますか? 3つのタプルを要素として、または 'RDD'の各行に3つのタプルがある場合、' RDD'を宣言していると思いますか? –

答えて

0

頂点とエッジrddの両方を修正する必要があると思います。

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

とエッジRDDそれはRDD [エッジ[edgeValueType]である:それはそうあなたがあなたの頂点RDDを変更する必要がRDDの[(VertexId、vertexValueType)]

ある

頂点RDD ] ので、確かに、それは次のようにする必要があります:

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

たぶん、あなたは、あなたが実際にこのRDDSを作成するコードを投稿することができますか?

関連する問題