Как я могу запустить "УДАЛИТЬ ИЗ ТАБЛИЦЫ" с JDBC в спарк 2.4? - PullRequest
0 голосов
/ 28 мая 2019

Я использую такой код:

spark.read.format("jdbc").options(Map("url" -> "jdbc:url"))

Мне нужно использовать DELETE FROM.

1 Ответ

1 голос
/ 28 мая 2019

DELETE / UPDATE не поддерживаются в Native Open source Spark.
Были предприняты некоторые усилия по обеспечению этой поддержки в рамках различных проектов с открытым исходным кодом, таких как HUDI , Iceberg , Delta .

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