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 8906b0dfeea [HUDI-5782] Tweak defaults and remove unnecessary configs
after config review (#8128)
add 84a14a4380f [HUDI-5880] Support partition pruning for flink streaming
source in runtime (#8102)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/source/FileIndex.java | 79 +++++-------
.../apache/hudi/source/IncrementalInputSplits.java | 33 ++---
.../hudi/source/StreamReadMonitoringFunction.java | 6 +-
.../apache/hudi/source/{ => prune}/DataPruner.java | 8 +-
.../apache/hudi/source/prune/PartitionPruners.java | 142 +++++++++++++++++++++
.../org/apache/hudi/table/HoodieTableSource.java | 103 +++++++--------
.../java/org/apache/hudi/util/ExpressionUtils.java | 87 +++++++++++++
.../hudi/source/TestExpressionEvaluators.java | 2 +-
.../hudi/source/TestIncrementalInputSplits.java | 79 ++++++++++--
.../apache/hudi/table/ITTestHoodieDataSource.java | 40 ++++++
.../apache/hudi/table/TestHoodieTableSource.java | 45 ++++---
.../apache/hudi/table/format/TestInputFormat.java | 26 ++--
12 files changed, 485 insertions(+), 165 deletions(-)
rename hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/{
=> prune}/DataPruner.java (96%)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java
