This is an automated email from the ASF dual-hosted git repository.
blue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from 079b84d Hive: Rename iceberg-hive to iceberg-hive-metastore (#1418)
add f153349 Flink: Support writing in SQL (#1348)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/flink/CatalogLoader.java | 54 ++++-
.../org/apache/iceberg/flink/FlinkCatalog.java | 19 +-
.../apache/iceberg/flink/FlinkTableFactory.java | 63 ++++++
.../org/apache/iceberg/flink/IcebergTableSink.java | 90 +++++++++
.../java/org/apache/iceberg/flink/TableLoader.java | 16 ++
.../org/apache/iceberg/flink/sink/FlinkSink.java | 20 +-
.../iceberg/flink/sink/IcebergFilesCommitter.java | 51 ++++-
.../apache/iceberg/flink/FlinkCatalogTestBase.java | 33 +++-
.../org/apache/iceberg/flink/SimpleDataUtil.java | 12 +-
.../iceberg/flink/TestFlinkCatalogDatabase.java | 5 +-
.../iceberg/flink/TestFlinkCatalogTable.java | 35 ++--
.../apache/iceberg/flink/TestFlinkTableSink.java | 220 +++++++++++++++++++++
.../flink/sink/TestIcebergFilesCommitter.java | 2 +-
13 files changed, 574 insertions(+), 46 deletions(-)
create mode 100644
flink/src/main/java/org/apache/iceberg/flink/FlinkTableFactory.java
create mode 100644
flink/src/main/java/org/apache/iceberg/flink/IcebergTableSink.java
create mode 100644
flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java
