pyspark & iceberg:`update *`在`merge into`中不工作?

svmlkihl  于 12个月前  发布在  Spark
关注(0)|答案(1)|浏览(85)

我在AWS EMR Studio上运行pyspark

MERGE INTO iceberg_catalog.staging.tbl AS t
USING tempview AS s
ON t.number = s.number
WHEN MATCHED THEN UPDATE *
WHEN NOT MATCHED THEN INSERT *

但得到

pyspark.sql.utils.ParseException:
Syntax error at or near '*'

知道为什么吗有什么东西丢了吗?

2q5ifsrm

2q5ifsrm1#

似乎update语句应该与update set语法一起使用。这是AWS Athena中使用的冰山表的示例,但请参考它。

  • https://docs.aws.amazon.com/ko_kr/athena/latest/ug/querying-iceberg-updating-iceberg-table-data.html#querying-iceberg-merge-into

相关问题