如何在 Apache Spark 中管理事务?

San*_*ori 5 transactions rollback apache-spark-sql

我想将 spark sql 用于数据持久化,如果事务在两者之间失败,我可以在 spark 中回滚事务吗?

例如,假设我们有 3 个表 t1、t2 和 t3。t1 和 t2 表数据成功持久化,但 t3 在数据完整性级别上失败了。我可以回滚保存在数据库中的 t1 和 t2 数据吗?

有没有什么火花方式来回滚事务?