我想使用列表过滤Spark数据框
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
并得到相同的错误。 最佳答案
您可以使用isin
函数,如下所示
var lisst=List(1,2,34)
df.filter(col("id").isin(lisst :_*))
希望这可以帮助!