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 025bac38168e feat: Add a new index write function for flink writer
(#17838)
add 0591ee45ae74 feat: add flink HoodieSourceSplitComparator (#18009)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/source/HoodieSource.java | 3 +-
.../source/split/DefaultHoodieSplitProvider.java | 16 ++
.../source/split/HoodieContinuousSplitBatch.java | 1 +
.../hudi/source/split/HoodieSourceSplit.java | 9 +-
.../source/split/HoodieSourceSplitComparator.java | 57 +++++
.../source/split/HoodieSourceSplitSerializer.java | 5 +
.../hudi/source/split/SerializableComparator.java | 9 +-
.../org/apache/hudi/source/TestHoodieSource.java | 1 +
.../TestHoodieContinuousSplitEnumerator.java | 1 +
.../TestHoodieEnumeratorStateSerializer.java | 3 +-
.../TestHoodieStaticSplitEnumerator.java | 1 +
.../apache/hudi/source/reader/TestBatchReader.java | 1 +
.../hudi/source/reader/TestDefaultBatchReader.java | 1 +
.../source/reader/TestHoodieRecordEmitter.java | 1 +
.../source/reader/TestHoodieSourceSplitReader.java | 1 +
.../split/TestDefaultHoodieSplitProvider.java | 176 +++++++++++++
.../hudi/source/split/TestHoodieSourceSplit.java | 29 +--
.../split/TestHoodieSourceSplitComparator.java | 273 +++++++++++++++++++++
.../split/TestHoodieSourceSplitSerializer.java | 43 ++--
19 files changed, 588 insertions(+), 43 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/HoodieSourceSplitComparator.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestHoodieSourceSplitComparator.java
