Scala中的Spark :如何比较两个列与它们不同的位置的数量？

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

// 创建一个SparkSession
val spark = SparkSession.builder()
  .appName("ColumnComparison")
  .master("local")
  .getOrCreate()

// 创建一个包含两个列的DataFrame
val df = spark.createDataFrame(Seq(
  (1, "apple"),
  (2, "banana"),
  (3, "orange")
)).toDF("id", "fruit")

// 定义两个列
val col1 = df("id")
val col2 = df("fruit")

// 使用内置函数进行比较
val diffCount = when(col1 =!= col2, 1).otherwise(0).as("diffCount")

// 添加一个新列，计算不同位置的数量
val result = df.withColumn("diffCount", diffCount)

// 显示结果
result.show()