如果值包含在scala spark中的列表中，如何过滤行？

Question

我想使用列表过滤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得到相同的错误。

Answer 1

您可以使用isin以下功能

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

希望这可以帮助！