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 931865ecaf Flink: port range distribution to v2 iceberg sink (#12071)
add 1260522673 Flink: Dynamic Iceberg Sink: Add table update code for
schema comparison and evolution (#13032)
No new revisions were added by this update.
Summary of changes:
.../flink/sink/dynamic/CompareSchemasVisitor.java | 266 +++++++++
.../flink/sink/dynamic/EvolveSchemaVisitor.java | 204 +++++++
.../flink/sink/dynamic/PartitionSpecEvolution.java | 137 +++++
.../flink/sink/dynamic/TableMetadataCache.java | 261 +++++++++
.../iceberg/flink/sink/dynamic/TableUpdater.java | 207 +++++++
.../sink/dynamic/TestCompareSchemasVisitor.java | 209 +++++++
.../sink/dynamic/TestEvolveSchemaVisitor.java | 623 +++++++++++++++++++++
.../sink/dynamic/TestPartitionSpecEvolution.java | 188 +++++++
.../flink/sink/dynamic/TestTableMetadataCache.java | 94 ++++
.../flink/sink/dynamic/TestTableUpdater.java | 160 ++++++
10 files changed, 2349 insertions(+)
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/CompareSchemasVisitor.java
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/EvolveSchemaVisitor.java
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/PartitionSpecEvolution.java
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableMetadataCache.java
create mode 100644
flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableUpdater.java
create mode 100644
flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestCompareSchemasVisitor.java
create mode 100644
flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestEvolveSchemaVisitor.java
create mode 100644
flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestPartitionSpecEvolution.java
create mode 100644
flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableMetadataCache.java
create mode 100644
flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestTableUpdater.java
