我在 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 '*'
知道为什么吗?这里有什么遗漏吗?
看来
update
语句应该与update set
语法一起使用。这是 AWS Athena 中使用的 Iceberg 表的示例,但请参考它。