Spark SQL 作为一个 ACID 单元执行多个命令

Question

有没有办法从 pySpark 强制多个 SQL 命令作为一个单元执行？ 我会的

Create table B;
Drop table A;
Rename table B as table A;

我希望他们作为一个整体执行。如果出现问题，例如 B 没有正确创建，我不想放弃 A。

Answer 1

在嵌套中使用 try 和 catch。然后你就可以控制事情了。但如果重命名失败，那又如何呢？从这个意义上说，酸的东西不会飞。