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 5c278d46fb1 [HUDI-6082] Mark advanced Flink configs (#8463)
add cc307d4899b [HUDI-6070] Files pruning for bucket index table pk
filtering queries (#8461)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/index/bucket/BucketIdentifier.java | 6 +-
.../apache/hudi/configuration/OptionsResolver.java | 7 +
.../sink/bucket/BucketStreamWriteFunction.java | 2 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 4 +-
.../java/org/apache/hudi/source/FileIndex.java | 132 ++++++++++++++----
.../apache/hudi/source/IncrementalInputSplits.java | 7 +-
.../hudi/source/prune/PrimaryKeyPruners.java | 75 +++++++++++
.../org/apache/hudi/table/HoodieTableSource.java | 41 +++++-
.../java/org/apache/hudi/util/ExpressionUtils.java | 69 ++++++++++
.../utils/BucketStreamWriteFunctionWrapper.java | 6 +-
.../hudi/sink/utils/InsertFunctionWrapper.java | 5 +
.../hudi/sink/utils/TestFunctionWrapper.java | 5 +
.../org/apache/hudi/sink/utils/TestWriteBase.java | 8 +-
.../java/org/apache/hudi/source/TestFileIndex.java | 6 +-
.../apache/hudi/table/ITTestHoodieDataSource.java | 30 +++++
.../apache/hudi/table/TestHoodieTableSource.java | 147 ++++++++++++++++++++-
.../org/apache/hudi/utils/TestConfigurations.java | 8 ++
.../test/java/org/apache/hudi/utils/TestData.java | 34 ++++-
18 files changed, 537 insertions(+), 55 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PrimaryKeyPruners.java
