pvary commented on issue #11720: URL: https://github.com/apache/iceberg/issues/11720#issuecomment-2526388257
Currently there is no native Iceberg way to partially update rows. Iceberg provides way to delete and insert rows. There is two types of delete: 1. Delete a given row from a file 2. Delete every record where a values of some specific fields equals the provided values. Engines need to construct their updates using these primitive operations. Flink currently only allows updating full records. If you want to archive the described functionality you need to keep the table data in state (keyed by the primary key, or some buckets over the primary key), and transform the partial updates to full updates, which could be sink to an Iceberg table -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
