Hi Iceberg dev team,
I am trying to use iceberg to do "upsert" based on an event table
In pure SQL, it is unsupported yet
Here is my example with 2 tables: "iceberg_table" should contain updated
data, and "table_event" contains event updates.
scala> spark.sql(""" MERGE INTO db1.iceberg_table t USING db1.table_event e
ON e.id = t.id WHEN MATCHED THEN UPDATE SET t.data = e.data WHEN NOT
MATCHED THEN INSERT (id, data) VALUES (id, data) """).show()
..
java.lang.UnsupportedOperationException: MERGE INTO TABLE is not supported
temporarily.
Is there a way to execute it programmatically using Spark Api or Iceberg
Api?
Any idea when the sql feature might be available ?
Thanks in advance
Regards,
Arnaud Nauwynck
