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 8de302bf48 API: Add geospatial bounding box types and implement
intersects checking (#12667)
add 87f0563ff5 Flink: Backort add TableCreator interface to set table
properties/location to 2.0 and 1.20 (#14607)
No new revisions were added by this update.
Summary of changes:
.../flink/sink/dynamic/DynamicIcebergSink.java | 16 ++++++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 8 +++-
.../sink/dynamic/DynamicTableUpdateOperator.java | 11 ++++-
.../iceberg/flink/sink/dynamic/TableCreator.java | 0
.../iceberg/flink/sink/dynamic/TableUpdater.java | 15 ++++--
.../dynamic/TestDynamicTableUpdateOperator.java | 6 ++-
.../flink/sink/dynamic/TestTableMetadataCache.java | 3 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++++++++++++++++-----
.../flink/sink/dynamic/DynamicIcebergSink.java | 16 ++++++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 8 +++-
.../sink/dynamic/DynamicTableUpdateOperator.java | 11 ++++-
.../iceberg/flink/sink/dynamic/TableCreator.java | 0
.../iceberg/flink/sink/dynamic/TableUpdater.java | 15 ++++--
.../dynamic/TestDynamicTableUpdateOperator.java | 6 ++-
.../flink/sink/dynamic/TestTableMetadataCache.java | 3 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++++++++++++++++-----
16 files changed, 172 insertions(+), 52 deletions(-)
copy flink/{v2.1 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableCreator.java
(100%)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/TableCreator.java
(100%)
