java - Pyspark 列表到 Scala 序列

Question

我有一个 scala 类，它接受一个参数，即 Pyspark List。

它适用于 ArrayList，但不适用于 Sequence。

我的代码是:

class HelloWorld(x: Seq[String]) {
    val elo = x
    ...

在 Pyspark 中我做:elo = sc._jvm.HelloWorld(["A", "B"]).someMethod()

我得到的错误是

py4j.Py4JException: Constructor com.matching.HelloWorld([class java.util.ArrayList]) does not exist

所以，我在 Scala 中import java.util.ArrayList 并且它有效，但我想避免 Scala 类型:序列并避免 Java 导入。

编辑:我看到这个: https://www.py4j.org/advanced_topics.html

我知道 Pyspark 使用 Py4J 来允许使用 Java 周围的 Python 包装器，因此它可以使用 JVM...但我希望 Scala 集合能够使用...

那么，我不能使用 Scala 序列吗？

Answer 1

导入 scala.collection.JavaConversions._;

x.toSeq 解决了问题。