You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by pv...@apache.org on 2025/06/26 19:27:25 UTC
(iceberg) branch main updated (dec1aa5cf7 -> 7443e54bbb)
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 dec1aa5cf7 Flink: Backports TableSchema migration to Flink 1.19 and 1.20 (#13392)
add 7443e54bbb Flink: Dynamic Iceberg Sink: Optimise RowData evolution (#13340)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/sink/dynamic/DataConverter.java | 235 +++++++++++++++++++++
.../flink/sink/dynamic/DynamicIcebergSink.java | 25 ++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 41 ++--
.../sink/dynamic/DynamicTableUpdateOperator.java | 28 ++-
.../iceberg/flink/sink/dynamic/LRUCache.java | 60 ++++++
.../iceberg/flink/sink/dynamic/RowDataEvolver.java | 190 -----------------
.../flink/sink/dynamic/TableMetadataCache.java | 123 ++++++-----
.../iceberg/flink/sink/dynamic/TableUpdater.java | 31 +--
.../dynamic/TestDynamicTableUpdateOperator.java | 12 +-
.../iceberg/flink/sink/dynamic/TestLRUCache.java | 90 ++++++++
...wDataEvolver.java => TestRowDataConverter.java} | 38 ++--
.../flink/sink/dynamic/TestTableMetadataCache.java | 20 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++--
13 files changed, 607 insertions(+), 339 deletions(-)
create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DataConverter.java
create mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/LRUCache.java
delete mode 100644 flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/RowDataEvolver.java
create mode 100644 flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestLRUCache.java
rename flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/{TestRowDataEvolver.java => TestRowDataConverter.java} (88%)