You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2022/03/04 19:14:20 UTC
[iceberg] branch master updated (89897e9 -> 98ee502)
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 89897e9 Docs: Fix typo in Java API Quickstart (#4256)
add 98ee502 Flink: Add FLIP-27 reader function that reads IcebergSourceSplit (#4234)
No new revisions were added by this update.
Summary of changes:
...atcher.java => DataIteratorReaderFunction.java} | 25 ++-
...ataIteratorBatcher.java => ReaderFunction.java} | 12 +-
.../flink/source/reader/RowDataReaderFunction.java | 70 +++++++
.../source/reader/ReaderFunctionTestBase.java | 218 +++++++++++++++++++++
.../iceberg/flink/source/reader/ReaderUtil.java | 75 +++++++
.../TestArrayPoolDataIteratorBatcherRowData.java | 60 ++----
.../source/reader/TestRowDataReaderFunction.java | 68 +++++++
7 files changed, 466 insertions(+), 62 deletions(-)
copy flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/reader/{DataIteratorBatcher.java => DataIteratorReaderFunction.java} (57%)
copy flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/reader/{DataIteratorBatcher.java => ReaderFunction.java} (67%)
create mode 100644 flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
create mode 100644 flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderFunctionTestBase.java
create mode 100644 flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
create mode 100644 flink/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java