python - Databricks 未在 SQL 查询中更新

Question

我正在尝试使用 SQL 和 SQL 查询替换表列中的特殊字符。但是，我收到以下错误。谁能告诉我我做错了什么或者我应该如何处理这个问题？

SQL 查询

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

错误

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

Answer 1

Databricks 仅支持 Delta(Delta Lake)表的更新。该错误消息表明您尝试对非增量表进行更新。因此，您必须将数据源转换为增量数据。对于 Parquet 来说非常简单:

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

请参阅Documentation了解更多详情。