2017-01-17 6 views

答えて

0

私は同様の問題がありましたが、それが可能かどうかまだ分かりません。私は少しの回避策を共有することができます。私の場合、すべての頂点にIDを割り当てました。それが助けてくれることを願っています。

val VertexRDD: RDD[(VertexId, Array[String])] = vfile.map(line => line.split(",")).zipWithIndex().map(_.swap) 
関連する問題