在结构列表中查找空值spark sql

import org.apache.spark.sql.SparkSession

object FindNullValues {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .appName("Find Null Values")
      .master("local")
      .getOrCreate()

    // 创建一个示例数据集
    val data = Seq(
      (1, "John", null),
      (2, "Alice", 25),
      (3, null, 30),
      (4, "Bob", 35)
    )

    // 将数据集转换为DataFrame
    import spark.implicits._
    val df = data.toDF("id", "name", "age")

    // 使用isNull()函数查找空值
    val nullValues = df.filter($"name".isNull || $"age".isNull)

    // 打印结果
    nullValues.show()
  }
}