スパーク - VertexID

Question

ことにより、2つのアレイに参加、私は次の形式で2つの配列を持っている

scala> cPV.take(5) 
res18: Array[(org.apache.spark.graphx.VertexId, String)] = Array((-496366541,7804412), (183389035,11517829), (1300761459,36164965), (978932066,32135154), (370291237,40355685)) 

scala> fC.take(5) 
res19: Array[(org.apache.spark.graphx.VertexId, Int)] = Array((386253628,1), (-1141923433,1), (1871855296,7), (1938255756,1), (-749015657,5)) 

私は形式に入るためにそれらを結合する必要が

- Array[(org.apache.spark.graphx.VertexId, Int, String)]

私は.join試してみました（）が、次のエラーが発生します

val mVP = fC.join(cPV) 
<console>:64: error: value join is not a member of Array[(org.apache.spark.graphx.VertexId, Int)] 
     val mVP = fC.join(cPV) 

また、thisを試しても動作しませんでした。

Answer 1

は、私は次のことを試してみましたし、それが

val fCRDD = sc.parallelize(fC) 
scala> val mVP = fCRDD.join(cPV) 
mVP: org.apache.spark.rdd.RDD[(org.apache.spark.graphx.VertexId, (Int, String))] = MapPartitionsRDD[106] at join at <console>:67 

scala> mVP.take(5) 
res21: Array[(org.apache.spark.graphx.VertexId, (Int, String))] = Array((-891966589,(4,D)), (166544732,(74,V)), (1871855296,(7,LG)), (1416009424,(6,Dck)), (-241988197,(4,L))) 

申し訳ありませんが働いていた、ここでNoobの - 私はここに質問を投稿する前にこれを試している必要があります。