在Spark 1.5+中,您可以使用
array_contains功能:
df.where(array_contains($"people.artist.id", "153"))
如果您使用的是较早版本,则可以尝试这样的UDF:
val containsId = udf( (rs: Seq[Row], v: String) => rs.map(_.getAs[String]("id")).exists(_ == v))df.where(containsId($"people.artist", lit("153")))


