This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 0704ab47fa Flink: Change to oldestAncestorAfter (#6401)
add 6ab1986e1e Flink: Support inspecting metadata table (#6222)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iceberg/types/ReassignDoc.java | 103 +++
.../java/org/apache/iceberg/types/TypeUtil.java | 22 +
.../java/org/apache/iceberg/BaseFilesTable.java | 35 +-
docs/flink-getting-started.md | 183 ++++-
.../org/apache/iceberg/flink/FlinkCatalog.java | 32 +-
.../org/apache/iceberg/flink/FlinkSchemaUtil.java | 3 +
.../apache/iceberg/flink/data/StructRowData.java | 300 ++++++++
.../iceberg/flink/source/DataTaskReader.java} | 28 +-
.../iceberg/flink/source/FlinkInputFormat.java | 16 +-
.../apache/iceberg/flink/source/IcebergSource.java | 29 +-
...erFunction.java => MetaDataReaderFunction.java} | 23 +-
.../org/apache/iceberg/flink/DataGenerators.java | 4 +-
.../java/org/apache/iceberg/flink/TestHelpers.java | 169 ++++-
.../iceberg/flink/data/TestStructRowData.java} | 42 +-
.../flink/source/TestFlinkMetaDataTable.java | 829 +++++++++++++++++++++
.../source/TestMetadataTableReadableMetrics.java | 175 +++--
16 files changed, 1832 insertions(+), 161 deletions(-)
create mode 100644 api/src/main/java/org/apache/iceberg/types/ReassignDoc.java
create mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/data/StructRowData.java
copy
flink/{v1.15/flink/src/main/java/org/apache/iceberg/flink/source/FileScanTaskReader.java
=>
v1.16/flink/src/main/java/org/apache/iceberg/flink/source/DataTaskReader.java}
(59%)
copy
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/source/reader/{RowDataReaderFunction.java
=> MetaDataReaderFunction.java} (77%)
copy
flink/{v1.14/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
=>
v1.16/flink/src/test/java/org/apache/iceberg/flink/data/TestStructRowData.java}
(61%)
create mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
copy {spark/v3.3/spark/src/test/java/org/apache/iceberg/spark =>
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink}/source/TestMetadataTableReadableMetrics.java
(66%)
