This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 35e2bbf9813f refactor: add import (#18428)
add 6079b6a7ed65 feat: support limit push down in Hudi Flink Source V2
(#18406)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/source/HoodieScanContext.java | 1 +
.../java/org/apache/hudi/source/HoodieSource.java | 2 +-
.../hudi/source/reader/HoodieSourceReader.java | 9 +-
.../source/reader/HoodieSourceSplitReader.java | 32 +-
.../apache/hudi/source/reader/RecordLimiter.java | 83 +++++
.../function/AbstractSplitReaderFunction.java | 67 ++++
.../function/HoodieCdcSplitReaderFunction.java | 30 +-
.../reader/function/HoodieSplitReaderFunction.java | 32 +-
.../org/apache/hudi/table/HoodieTableSource.java | 7 +-
.../source/reader/TestHoodieSourceSplitReader.java | 198 ++++++++++-
.../hudi/source/reader/TestRecordLimiter.java | 372 +++++++++++++++++++++
.../function/TestAbstractSplitReaderFunction.java | 246 ++++++++++++++
.../function/TestHoodieCdcSplitReaderFunction.java | 53 +++
.../function/TestHoodieSplitReaderFunction.java | 58 ++++
.../apache/hudi/table/ITTestHoodieDataSource.java | 55 +++
15 files changed, 1169 insertions(+), 76 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/reader/RecordLimiter.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/reader/function/AbstractSplitReaderFunction.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/reader/TestRecordLimiter.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/reader/function/TestAbstractSplitReaderFunction.java
