This is an automated email from the ASF dual-hosted git repository.
openinx pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from 2ae65ac API: Refactor RewriteDataFiles and BinPackStrategy (#2600)
add a0d6cdf Flink: Support SQL primary key (#2410)
No new revisions were added by this update.
Summary of changes:
api/src/main/java/org/apache/iceberg/Schema.java | 4 +-
.../org/apache/iceberg/flink/FlinkCatalog.java | 6 +-
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 55 +++-
.../org/apache/iceberg/flink/IcebergTableSink.java | 8 +
.../org/apache/iceberg/flink/SimpleDataUtil.java | 10 +-
.../apache/iceberg/flink/TestChangeLogTable.java | 306 +++++++++++++++++++++
.../iceberg/flink/TestFlinkCatalogTable.java | 39 +++
.../apache/iceberg/flink/TestFlinkSchemaUtil.java | 55 ++++
.../iceberg/flink/source/BoundedTableFactory.java | 151 ++++++++++
.../iceberg/flink/source/BoundedTestSource.java | 8 +-
.../flink/source/ChangeLogTableTestBase.java | 93 +++++++
.../flink/source/TestBoundedTableFactory.java | 81 ++++++
.../org.apache.flink.table.factories.Factory} | 2 +-
13 files changed, 806 insertions(+), 12 deletions(-)
create mode 100644
flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
create mode 100644
flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
create mode 100644
flink/src/test/java/org/apache/iceberg/flink/source/ChangeLogTableTestBase.java
create mode 100644
flink/src/test/java/org/apache/iceberg/flink/source/TestBoundedTableFactory.java
copy
flink/src/{main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
=> test/resources/META-INF/services/org.apache.flink.table.factories.Factory}
(93%)
