sparksql作为一个acid单元执行多个命令

9nvpjoqh  于 2021-06-25  发布在  Hive
关注(0)|答案(1)|浏览(375)

有没有办法从pyspark强制多个sql命令作为一个单元执行?我要一杯

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

我希望他们作为一个整体执行。如果出了问题,比如b没有正确创建,我就不想删除a。

7y4bm7vi

7y4bm7vi1#

在嵌套中使用try-and-catch。你就能控制一切。但是如果重命名失败了,那怎么办?从这个意义上说,酸的东西不会飞。

相关问题