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 9a58a844d Format: Fix broken link to Parquet LogicalTypes in spec.md
(#5352)
add 23c9345d4 Flink: Support FLIP-27 source through SQL (#5318)
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 ++++++++----
.../flink/{ => source}/IcebergTableSource.java | 40 +++-
.../apache/iceberg/flink/source/SourceUtil.java | 102 +++++++++
.../flink/source/assigner/SplitAssignerType.java} | 17 +-
.../source/enumerator/StaticIcebergEnumerator.java | 37 ----
.../iceberg/flink/HadoopCatalogResource.java | 70 ++++++
.../apache/iceberg/flink/HadoopTableResource.java | 30 +--
.../org/apache/iceberg/flink/SimpleDataUtil.java | 2 +-
.../apache/iceberg/flink/source/SqlHelpers.java | 60 ++++++
.../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 | 85 ++++++++
.../flink/{ => source}/TestFlinkTableSource.java | 3 +-
.../flink/source/TestIcebergSourceBounded.java | 29 +--
.../flink/source/TestIcebergSourceBoundedSql.java | 80 +++++++
.../iceberg/flink/source/TestIcebergSourceSql.java | 42 ++++
.../iceberg/flink/source/TestSourceUtil.java | 60 ++++++
.../apache/iceberg/flink/source/TestSqlBase.java | 158 ++++++++++++++
23 files changed, 900 insertions(+), 467 deletions(-)
rename flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/{ =>
source}/IcebergTableSource.java (81%)
create mode 100644
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/SourceUtil.java
copy
flink/{v1.14/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.java
=>
v1.15/flink/src/main/java/org/apache/iceberg/flink/source/assigner/SplitAssignerType.java}
(73%)
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/HadoopCatalogResource.java
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/SqlHelpers.java
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceSql.java
rename flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/{ =>
source}/TestFlinkTableSource.java (99%)
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceBoundedSql.java
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestSourceUtil.java
create mode 100644
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestSqlBase.java
