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]