Scala比较2个Spark数据帧中的值

import org.apache.spark.sql.SparkSession

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

    import spark.implicits._

    // 创建两个数据帧
    val df1 = Seq((1, "Alice"), (2, "Bob"), (3, "Charlie")).toDF("id", "name")
    val df2 = Seq((1, "Alice"), (2, "Bob"), (4, "Dave")).toDF("id", "name")

    // 比较两个数据帧中的值
    val comparison = df1.except(df2)

    if (comparison.count() == 0) {
      println("两个数据帧中的值相同")
    } else {
      println("两个数据帧中的值不同")
      comparison.show()
    }

    spark.stop()
  }
}