laskoviymishka opened a new pull request, #892: URL: https://github.com/apache/iceberg-go/pull/892
Add Transaction.RewriteDataFiles() that reads data with deletes applied, writes new consolidated files, and atomically replaces old files via ReplaceFiles. Position delete files matched to rewritten data files are removed in the same commit. - CompactionTaskGroup bridges compaction planner and executor (avoids circular import between table/ and table/compaction/) - collectSafePositionDeletes only removes pos deletes with explicit content type check; equality deletes preserved (may apply outside scope) - Context cancellation checked between groups - Empty groups skipped gracefully E2e tests with real Parquet files: - Small file compaction (5→1 file, row count preserved) - Position delete cleanup (delete applied, delete file removed) - Empty plan / empty group handling - Partial progress mode - Context cancellation Part of #832 (table compaction). -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
