1
我正在使用spark 1.4.0和graphx,我的图形边缘存储在文件中,我使用以下代码行 将它们存储在RDD中。我想用EdgeRDD代替RDD [边缘[字符串]如何在Graphx中创建EdgeRDD
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)
我怎样才能解决这个问题。
谢谢。这对我有效。 – SanS