我想使用列表过滤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)

我尝试使用SeqSet并得到相同的错误。

最佳答案

您可以使用isin函数,如下所示

var lisst=List(1,2,34)
 df.filter(col("id").isin(lisst :_*))

希望这可以帮助!

08-27 10:08