This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 pushed a change to branch HUDI-8990-V2
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 03e1d51f1ab partitial update based on code review && fix ut
add 3f6a429f970 finish code review
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/config/HoodieLayoutConfig.java | 12 +-
.../bucket/partition/HoodieSimpleBucketIndex.java | 15 +-
.../index/bucket/partition/NumBucketsFunction.java | 104 ++++++++++
.../BucketIndexBulkInsertPartitionerWithRows.java | 31 +--
.../RDDSimpleBucketBulkInsertPartitioner.java | 29 +--
.../BucketBulkInsertDataInternalWriterHelper.java | 16 +-
.../action/commit/SparkBucketIndexPartitioner.java | 85 +-------
...a => SparkPartitionBucketIndexPartitioner.java} | 72 +++----
.../apache/spark/sql/BucketPartitionUtils.scala | 42 +---
.../sink/bucket/BucketBulkInsertWriterHelper.java | 13 +-
.../sink/bucket/BucketStreamWriteFunction.java | 23 +--
.../sink/partitioner/BucketIndexPartitioner.java | 23 +--
.../BaseDatasetBulkInsertCommitActionExecutor.java | 3 +-
.../DatasetBucketRescaleCommitActionExecutor.java | 3 +-
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 14 +-
.../TestInsertTableWithPartitionBucketIndex.scala | 224 ++++++++++-----------
16 files changed, 314 insertions(+), 395 deletions(-)
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/partition/NumBucketsFunction.java
copy
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/{SparkBucketIndexPartitioner.java
=> SparkPartitionBucketIndexPartitioner.java} (74%)
