Open yimlin opened 9 months ago
If you are updating based on a table key, then upsert
mode can help you:
https://iceberg.apache.org/docs/latest/flink-writes/#upsert
INSERT INTO tableName /*+ OPTIONS('upsert-enabled'='true') */
...
Other than that, it is a totally new statement to support, and it would take a while to implement it.
Thanks very much. as you know, the trino engine also suppport update statement, it's better for iceberg that it has the same behaviors in different engines.
This issue has been automatically marked as stale because it has been open for 180 days with no activity. It will be closed in next 14 days if no further activity occurs. To permanently prevent this issue from being considered stale, add the label 'not-stale', but commenting on the issue is preferred when possible.
Feature Request / Improvement
As in the spark engine, we can apply update-statement, but we can't do the same thing in the flink engine. So please add update-statement support in the Flink engine
Query engine
Flink