并行化从Java获取的List [String]并在Scala中使用以创建RDD时出错-Java 学习之路

-1

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

类型不匹配;

[ error ]发现：java.util.List [String]

[ error ]必需：Seq [String]

[ error ]涉及默认参数的应用程序出错 .

[ error ] val vertexRDD：RDD [（String）] = sc.parallelize（ g.vertexArray ）

1 回答

您应该导入以下内容：

import scala.collection.JavaConverters._

然后用

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

回复于 2024-05-05T06:41:54+08:00

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

1 回答

相关问题