This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 6ca4c40bc5a7 fix: Handle nested map and array columns in MDT (#17694)
add 29c819f86e02 feat: add basic hoodie source (#17989)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/source/HoodieSource.java | 160 ++++++
.../java/org/apache/hudi/source/ScanContext.java | 19 +-
.../HoodieEnumeratorStateSerializer.java | 120 +++++
.../source/split/HoodieSourceSplitSerializer.java | 144 ++++++
.../org/apache/hudi/source/TestHoodieSource.java | 554 +++++++++++++++++++++
.../org/apache/hudi/source/TestScanContext.java | 149 ++++++
.../TestHoodieContinuousSplitEnumerator.java | 4 +-
.../TestHoodieEnumeratorStateSerializer.java | 496 ++++++++++++++++++
.../split/TestHoodieSourceSplitSerializer.java | 466 +++++++++++++++++
9 files changed, 2108 insertions(+), 4 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/enumerator/HoodieEnumeratorStateSerializer.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/HoodieSourceSplitSerializer.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestHoodieSource.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieEnumeratorStateSerializer.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestHoodieSourceSplitSerializer.java
