Spark Scala:从另一个dataframe更新dataframe列的值

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

// 创建SparkSession
val spark = SparkSession.builder()
  .appName("Update DataFrame Column")
  .getOrCreate()

// 创建第一个DataFrame
val df1 = spark.createDataFrame(Seq(
  (1, "John"),
  (2, "Jane"),
  (3, "Alice")
)).toDF("id", "name")

// 创建第二个DataFrame
val df2 = spark.createDataFrame(Seq(
  (1, "Engineer"),
  (2, "Manager"),
  (3, "Analyst")
)).toDF("id", "job")

// 进行连接操作
val joinedDF = df1.join(df2, Seq("id"))

// 更新列值
val updatedDF = joinedDF.withColumn("name", lit("Updated Name"))

// 显示更新后的DataFrame
updatedDF.show()