apache-spark - 如何在 Graphx 中创建 EdgeRDD

Question

我正在使用 spark 1.4.0 和 graphx，我将图形边缘存储在文件中，我使用以下代码行将它们存储在 RDD 中。我想使用 EdgeRDD 而不是 RDD[Edge[String]]

val edges: RDD[Edge[String]] = edge_file.map(line => {val x = line.split("\\s+")
Edge(x(0).toLong, x(1).toLong, " "); })

我试过这个

val edgesRDD = EdgeRDD(edges)

我该如何解决这个问题。

Answer 1

EdgeRDD.fromEdges(edges)应该做的伎俩。