This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from b69480aecd9 [MINOR] Replace hard-coded path by temp dir in tests
(#11912)
add 845885a271d [HUDI-8071] Handle skew for user defined sort columns in
BULK_INSERT (#11758)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/config/HoodieWriteConfig.java | 11 +++
.../apache/hudi/table/BulkInsertPartitioner.java | 36 -------
.../JavaCustomColumnsSortPartitioner.java | 23 ++---
.../RDDCustomColumnsSortPartitioner.java | 19 ++--
.../RowCustomColumnsSortPartitioner.java | 45 ++++++++-
.../TestRowCustomColumnsSortPartitioner.java | 52 ++++++++++
.../java/org/apache/hudi/avro/HoodieAvroUtils.java | 31 ++++++
.../org/apache/hudi/common/util/SortUtils.java | 77 +++++++++++++++
.../org/apache/hudi/avro/TestHoodieAvroUtils.java | 26 +++++
.../org/apache/hudi/common/util/TestSortUtils.java | 110 +++++++++++++++++++++
.../TestBulkInsertInternalPartitionerForRows.java | 13 ++-
.../deltastreamer/TestHoodieDeltaStreamer.java | 37 +++++++
12 files changed, 415 insertions(+), 65 deletions(-)
create mode 100644
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestRowCustomColumnsSortPartitioner.java
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/SortUtils.java
create mode 100644
hudi-common/src/test/java/org/apache/hudi/common/util/TestSortUtils.java