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 017e81300c [Docs] Add Spark MERGE INTO fields in snapshot summary
(#15390)
add 10de214108 Flink: Backport SQL support for dynamic iceberg sink
(#15444)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/FlinkCreateTableOptions.java | 18 ++
.../iceberg/flink/FlinkDynamicTableFactory.java | 99 ++++++---
.../org/apache/iceberg/flink/IcebergTableSink.java | 235 +++++++++++++++------
.../sink/dynamic/DynamicTableRecordGenerator.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 155 +++++++++++++-
.../iceberg/flink/FlinkCreateTableOptions.java | 18 ++
.../iceberg/flink/FlinkDynamicTableFactory.java | 99 ++++++---
.../org/apache/iceberg/flink/IcebergTableSink.java | 233 ++++++++++++++------
.../sink/dynamic/DynamicTableRecordGenerator.java | 0
.../apache/iceberg/flink/TestIcebergConnector.java | 155 +++++++++++++-
10 files changed, 820 insertions(+), 192 deletions(-)
copy flink/{v2.1 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicTableRecordGenerator.java
(100%)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicTableRecordGenerator.java
(100%)
