aiborodin

Optimise RowData evolution

1

RowDataEvolver recomputes Flink RowType and field getters for every input record that needs to match a destination Iceberg table schema. Cache field getters and column converters to optimise RowData conversion.

This PR re-opens https://github.com/apache/iceberg/pull/14312.

Implement Snapshot validation API for commits

6

This change implements the ability to add custom `Snapshot` validations to the existing `SnapshotUpdate` API. It focuses on reusing existing validation APIs in `SnapshotProducer` and removing code duplication, while providing...

Validate parent snapshots in Kafka Connect

3

This change uses the new API in https://github.com/apache/iceberg/pull/14514 to validate that no concurrent commit has moved the Kafka offsets that would not be seen by the committer due to the...