pyspark 和 Iceberg:“更新 *”在“合并到”中不起作用?

问题描述 投票:0回答:1

我在 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 '*'

知道为什么吗?这里有什么遗漏吗?

apache-spark pyspark apache-spark-sql amazon-emr iceberg
1个回答
0
投票

看来

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

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.