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 135db099afc [MINOR] Remove redundant fileId from HoodieAppendHandle
(#10901)
add 5a21a1dd260 [HUDI-7529] Resolve hotspots in stream read (#10911)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/configuration/OptionsResolver.java | 18 +++++++++
.../partitioner/StreamReadAppendPartitioner.java} | 27 ++++---------
.../StreamReadBucketIndexPartitioner.java} | 29 +++++---------
.../selector/StreamReadAppendKeySelector.java} | 26 +++----------
.../StreamReadBucketIndexKeySelector.java} | 26 +++----------
.../org/apache/hudi/table/HoodieTableSource.java | 45 ++++++++++++++--------
6 files changed, 76 insertions(+), 95 deletions(-)
copy
hudi-flink-datasource/hudi-flink/src/{test/java/org/apache/hudi/sink/utils/MockValueState.java
=>
main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadAppendPartitioner.java}
(67%)
copy
hudi-flink-datasource/hudi-flink/src/{test/java/org/apache/hudi/sink/utils/ScalaCollector.java
=>
main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadBucketIndexPartitioner.java}
(62%)
copy
hudi-flink-datasource/hudi-flink/src/{test/java/org/apache/hudi/sink/utils/MockValueState.java
=>
main/java/org/apache/hudi/source/filedistribution/selector/StreamReadAppendKeySelector.java}
(66%)
copy
hudi-flink-datasource/hudi-flink/src/{test/java/org/apache/hudi/sink/utils/MockValueState.java
=>
main/java/org/apache/hudi/source/filedistribution/selector/StreamReadBucketIndexKeySelector.java}
(66%)
