Hi folks, I'm processing data from an Iceberg table with Flink and had a question about positional deletes.
I batch process a source Table to create DataStream of Records that I'd like to delete from it. I initially created equality delete files with all the values from these Records, but for performance purposes I'd like to try out positional deletes. Given a Record from a Table, how can I go about identifying its position? A fellow from the Slack mentioned in Spark there's a "_pos" metadata field but I haven't found the equivalent in Java or Flink. best, ah ________________________________ Your Personal Data: We may collect and process information about you that may be subject to data protection laws. For more information about how we use and disclose your personal data, how we protect your information, our legal basis to use your information, your rights and who you can contact, please refer to: www.gs.com/privacy-notices<http://www.gs.com/privacy-notices>
