且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

如何根据列值是否在 Spark DataFrame 中的一组字符串中过滤行

更新时间:2022-12-10 07:47:21

这个怎么样:

myDF.filter("action in (1,2)")

import org.apache.spark.sql.functions.lit       
myDF.where($"action".in(Seq(1,2).map(lit(_)):_*))

import org.apache.spark.sql.functions.lit       
myDF.where($"action".in(Seq(lit(1),lit(2)):_*))

将在 1.5 中添加额外的支持以使其更清晰