如何在 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) 应该可以解决问题。