python SQL查询中的数据块未更新

eanckbw9  于 2022-12-17  发布在  Python
关注(0)|答案(2)|浏览(154)

我试图使用SQL查询替换表列中的特殊字符。但是,我得到了以下错误。谁能告诉我哪里做错了,或者我应该如何处理这个错误?

SQL查询

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

错误

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

9lowa7mx1#

Databricks只支持delta(delta lake)表的更新。错误消息表明您尝试在非delta表上更新。因此您必须将数据源转换为delta。对于 parquet ,这非常简单:

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

有关详细信息,请参见文档。

uajslkp6

uajslkp62#

转换为DELTA parquet 。s3://path/to/table除以(column_name整数);
--对分区表尝试此操作

相关问题