scala - 我们可以使用 Scala 对 Databricks Delta 表执行 UPDATE 和 DELETE 操作吗？

Question

我能够使用 scala 创建 databricks 增量表，并能够对其执行追加和覆盖操作。

有什么方法可以使用 scala 而不是通过 Databricks 运行时执行 DELETE 和 UPDATE 操作。

val target = Seq(
  Data("a", "0"),
  Data("b", "1"),
  Data("c", "2"),
  Data("d", "3")
).toDF().write.format("delta").mode("overwrite").saveAsTable("target")
val DF1 = spark.table("target")
DF1.show()

val NewInserts = Seq(
  Data("a", "0"),
  Data("b", "1"),
  Data("c", "2"),
  Data("d", "3")
).toDF().write.format("delta").mode("append").saveAsTable("target")

val DF2 = spark.table("target")
DF2.show()

Answer 1

还没有！只有 sql 命令支持更新/删除/合并。Databricks 正在努力发布 scala/python 等价物。