Spark如何在Scala中获取两个JSONS中更改的键数？

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._

val spark = SparkSession.builder()
  .appName("JSON Comparison")
  .master("local")
  .getOrCreate()

val json1 = spark.read.json("path/to/json1.json")
val json2 = spark.read.json("path/to/json2.json")

val keys1 = json1.columns.toSet
val keys2 = json2.columns.toSet

val addedKeys = keys2 -- keys1
val removedKeys = keys1 -- keys2
val changedKeys = keys1.intersect(keys2).filter { key =>
  json1.select(col(key)).except(json2.select(col(key))).count() > 0 ||
  json2.select(col(key)).except(json1.select(col(key))).count() > 0
}

println("Added keys: " + addedKeys.mkString(", "))
println("Removed keys: " + removedKeys.mkString(", "))
println("Changed keys: " + changedKeys.mkString(", "))