Перенести оператор обновления с сервера SQL для запуска с использованием DataFrames - PullRequest
0 голосов
/ 21 октября 2019

Мне нужно перенести оператор sql в приведенном ниже формате на spark. Пожалуйста, дайте мне знать эквивалент.

Update tab1
set tab1.col1 = tab4.col5
from tab1
inner join tab2
on tab1.col1 = tab2.col2
and tab2.col5 in ('abc','def')
left join tab3
on tab3.col1 - tab1.col6
and tab3.col7 = 'blablabla'
inner join tab4
on tab1.col8 = tab4.col2
and tab4.col1 = ...
and tab4.col5 = ...

Аналогичным образом, в одном столбце есть несколько обновлений - tab1.col1 с разными логиками.

Я знаю, что обновление не поддерживается в spark, но есть ли другой способ для достижения этой цели

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