Блоки данных не обновляются в запросе SQL - PullRequest
0 голосов
/ 29 мая 2019

Я пытаюсь заменить специальные символы из столбца таблицы с помощью SQL-запроса SQL. Однако я получаю следующую ошибку. Может кто-нибудь сказать мне, что я сделал не так или как мне к этому подойти?

SQL QUERY

UPDATE wine SET description = REPLACE(description, '%', '')

ERROR

error in sql statement: analysisexception: update destination only supports delta sources.

1 Ответ

0 голосов
/ 30 мая 2019

Databricks поддерживает только обновления таблиц delta (delta lake).Сообщение об ошибке указывает на то, что вы пытаетесь выполнить обновление для не-дельта-таблицы.Таким образом, вам придется конвертировать ваш источник данных в дельту.Для паркета это очень просто:

CONVERT TO DELTA parquet.`path/to/table` [NO STATISTICS]
[PARTITIONED BY (col_name1 col_type1, col_name2 col_type2, ...)]

См. Документация для более подробной информации.

...