WrappedArray$ofRef 不能转换为 scala.collection.immutable.Seq

Posted

技术标签:

【中文标题】WrappedArray$ofRef 不能转换为 scala.collection.immutable.Seq【英文标题】:wrappedArray$ofRef cannot be cast to scala.collection.immutable.Seq 【发布时间】:2021-10-26 15:59:01 【问题描述】:

我正在尝试将一些 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"
)

但我收到以下错误:

执行用户定义失败 函数(col_c(数组(字符串),数组(字符串)=>字符串 scala.collection.mutable.wrappedArray$ofRef 不能转换为 scala .collection.immutable.Seq

有什么建议可以防止这个错误吗?

【问题讨论】:

【参考方案1】:

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

看起来你已经导入了scala.collection.immutable.Seq,因此出现了错误。

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

【讨论】:

以上是关于WrappedArray$ofRef 不能转换为 scala.collection.immutable.Seq的主要内容,如果未能解决你的问题,请参考以下文章

Spark 2 将 scala 数组转换为 WrappedArray

如何在 Spark Scala 中将 WrappedArray 转换为 List?

Scala 将 WrappedArray 或 Array[Any] 转换为 Array[String]

将 Any 转换为数组 [重复]

WrapedArray 的 WrappedArray 到 java 数组

WrappedArray 的 Spark Dataframe 到 Dataframe[Vector]