如何在 Spark 2.4 中使用 jdbc 运行"DELETE FROM TABLE"？

Question

我正在使用这样的代码：

spark.read.format("jdbc").options(Map("url" -> "jdbc:url"))

我需要使用DELETE FROM.

Answer 1

DELETE/UPDATE 在原生开源 Spark 中不受支持。
在将这种支持作为各种开源项目(如HUDI，Iceberg，Delta(的一部分方面，已经做出了一些努力。