java - 并行化从 Java 中获取并在 Scala 中用于创建 RDD 的 List[String] 时出错

Question

var g = Graphx.graph() // return an Object with 2 Lists : List<Edge> edgeArray 
                      //                                  List<String> vertexArray  
val vertexRDD: RDD[(String)] = sc.parallelize(g.vertexArray)

类型不匹配;

[错误] 发现：java.util.List[String]

[错误]需要：Seq[String]

[错误] 涉及默认参数的应用程序发生错误。

[错误] val vertexRDD: RDD[(String)] = sc.parallelize( g.vertexArray )

Answer 1

您应该导入以下内容：

import scala.collection.JavaConverters._

然后使用

val vertexRDD: RDD[(String)] = sc.parallelize(g.vertexArray.asScala)