spark-sql中的update语句

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Spark SQL Update")
  .getOrCreate()

// 创建一个DataFrame
val df = spark.read.format("csv").option("header", "true").load("data.csv")

// 更新数据
val updatedDF = df.filter(df("id") === 1).withColumn("name", lit("New Name"))

// 将更新后的数据写入到新的表中
updatedDF.write.format("csv").mode("overwrite").save("updated_data.csv")

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Spark SQL Update")
  .getOrCreate()

// 创建一个临时视图
spark.read.format("csv").option("header", "true").load("data.csv").createOrReplaceTempView("my_table")

// 执行更新操作
spark.sql("UPDATE my_table SET name = 'New Name' WHERE id = 1")

// 将更新后的数据写入到新的表中
spark.sql("SELECT * FROM my_table").write.format("csv").mode("overwrite").save("updated_data.csv")