如果值包含在scala spark中的列表中,如何过滤一行? [英] How to filter a row if the value contains in list in scala spark?
本文介绍了如果值包含在scala spark中的列表中,如何过滤一行?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我想使用列表过滤火花数据框,例如
I want to filter a spark dataframe using list, for example
var lisst=List(1,2,34)
df.filter(col("id).isin(lisst))
给出错误
Unsupported literal type classscala.collection.immutable.$colon$colon
List(1,2,34)
我尝试使用 Seq
和 Set
并得到相同的错误.
I tried with Seq
and Set
and get same error.
推荐答案
您可以使用isin
函数如下
var lisst=List(1,2,34)
df.filter(col("id").isin(lisst :_*))
希望这会有所帮助!
这篇关于如果值包含在scala spark中的列表中,如何过滤一行?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文