wrappedArray$ofRef 无法转换为 scala.collection.immutable.Seq

Question

我正在尝试将一些 Python 代码转换为 Scala。

Python代码：

def col_c(o_row_ids,n_row_ids):
    o_set=set(o_row_ids)
    n_set=set(n_row_ids)
    if o_set=n_set
        return "in"
    elif o_set < n_set:
        return "Me"
    elif n_set < o_set:
        return "Sp"
    return "SM"

Scala 代码：

def col_c: UserDefinedFunction = udf((o_row_ids:Seq[String], n_row_ids: Seq[String]) => {
    val o_set = o_row_ids.toSet.count(z => true) //set(o_row_ids)
    val n_set = n_row_ids.toSet.count(z=> true)
    if (o_set == n_set)
        "In"
    else if( o_set < n_set)
        "Me"
    else if (n_set < o_set)
        "Sp"
    else "SM"
})

但我收到以下错误：

failed to execute user defined function(col_c(array(string),array(string)=>string scala.collection.mutable.wrappedArray$ofRef cannot be cast to scala .collection.immutable.Seq

关于如何防止此错误的任何建议？

Answer 1

WrappedArray 扩展 scala.collection.mutable.Seq 本身扩展 scala.collection.Seq.

您似乎导入了 scala.collection.immutable.Seq，因此出错了。

解决您的问题的一种方法是输入您的 UDF，输入为 scala.collection.Seq。