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 23c9345d4 Flink: Support FLIP-27 source through SQL (#5318)
add 41570a187 Flink 1.14: Support FLIP-27 source through SQL (#5344)
No new revisions were added by this update.
Summary of changes:
.../apache/iceberg/flink/FlinkConfigOptions.java | 23 +
.../iceberg/flink/FlinkDynamicTableFactory.java | 1 +
.../apache/iceberg/flink/source/FlinkSource.java | 86 +--
.../apache/iceberg/flink/source/IcebergSource.java | 133 +++--
.../iceberg/flink/source/IcebergTableSource.java | 4 +-
.../apache/iceberg/flink/source/SourceUtil.java | 0
.../flink/source/assigner/SplitAssignerType.java | 0
.../source/enumerator/StaticIcebergEnumerator.java | 37 --
.../iceberg/flink/HadoopCatalogResource.java | 0
.../apache/iceberg/flink/HadoopTableResource.java | 30 +-
.../org/apache/iceberg/flink/SimpleDataUtil.java | 2 +-
.../apache/iceberg/flink/TestFlinkTableSource.java | 653 ---------------------
.../apache/iceberg/flink/source/SqlHelpers.java | 0
.../iceberg/flink/source/TestFlinkInputFormat.java | 10 +-
.../apache/iceberg/flink/source/TestFlinkScan.java | 59 +-
.../iceberg/flink/source/TestFlinkScanSql.java | 236 +-------
.../iceberg/flink/source/TestFlinkSource.java | 4 +-
.../iceberg/flink/source/TestFlinkSourceSql.java | 0
.../iceberg/flink/source/TestFlinkTableSource.java | 0
.../flink/source/TestIcebergSourceBounded.java | 29 +-
.../flink/source/TestIcebergSourceBoundedSql.java | 0
.../iceberg/flink/source/TestIcebergSourceSql.java | 0
.../iceberg/flink/source/TestSourceUtil.java | 0
.../apache/iceberg/flink/source/TestSqlBase.java | 0
24 files changed, 195 insertions(+), 1112 deletions(-)
copy flink/{v1.15 =>
v1.14}/flink/src/main/java/org/apache/iceberg/flink/source/IcebergTableSource.java
(97%)
copy flink/{v1.15 =>
v1.14}/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java
(100%)
delete mode 100644
flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSource.java
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
(100%)
copy flink/{v1.15 =>
v1.14}/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
(100%)
