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 0c194502b8 OpenAPI: Use `PrimitiveTypeValue` rather than `object`
(#14184)
add a739cb3db8 Flink: Dynamic Sink: Add support for dropping columns
(#14728)
No new revisions were added by this update.
Summary of changes:
docs/docs/flink-writes.md | 17 ++-
.../flink/sink/dynamic/CompareSchemasVisitor.java | 18 +--
.../flink/sink/dynamic/DynamicIcebergSink.java | 19 ++++
.../flink/sink/dynamic/DynamicRecordProcessor.java | 7 +-
.../sink/dynamic/DynamicTableUpdateOperator.java | 6 +-
.../flink/sink/dynamic/EvolveSchemaVisitor.java | 47 ++++++--
.../flink/sink/dynamic/TableMetadataCache.java | 10 +-
.../iceberg/flink/sink/dynamic/TableUpdater.java | 17 ++-
.../sink/dynamic/TestCompareSchemasVisitor.java | 62 +++++++++++
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 49 ++++++++
.../dynamic/TestDynamicTableUpdateOperator.java | 82 ++++++++++++++
.../sink/dynamic/TestEvolveSchemaVisitor.java | 124 ++++++++++++++++-----
.../flink/sink/dynamic/TestTableMetadataCache.java | 25 +++--
.../flink/sink/dynamic/TestTableUpdater.java | 45 ++++++--
14 files changed, 445 insertions(+), 83 deletions(-)
