This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 99ccfc4b7b Spark: enable stream-results option for remove orphan files
(#14278)
add 4e68ff0080 Flink: Preserve row lineage in RewriteDataFiles (#14149)
No new revisions were added by this update.
Summary of changes:
.../operator/DataFileRewritePlanner.java | 6 --
.../operator/DataFileRewriteRunner.java | 34 ++++--
.../flink/source/RowDataFileScanTaskReader.java | 9 +-
.../org/apache/iceberg/flink/SimpleDataUtil.java | 30 +++++-
.../maintenance/api/TestRewriteDataFiles.java | 115 +++++++++++++++++++++
.../maintenance/operator/OperatorTestBase.java | 76 ++++++++++++--
.../operator/TestDataFileRewritePlanner.java | 13 ---
.../operator/TestDataFileRewriteRunner.java | 20 ++++
8 files changed, 256 insertions(+), 47 deletions(-)
