Spark SQL выполняет несколько команд как блок ACID - PullRequest
0 голосов
/ 31 октября 2019

Есть ли способ заставить несколько команд SQL выполняться как единое целое из pySpark? У меня будет

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

Я бы хотел, чтобы они выполнялись как единое целое. Если что-то пойдет не так, как, например, B не создан должным образом, я бы не хотел отбрасывать A.

1 Ответ

0 голосов
/ 01 ноября 2019

Используйте try and catch с вложенностью. Тогда вы можете контролировать вещи. Но если переименовать не удалось, что тогда? В этом смысле КИСЛОТА не летит.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...