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 16ffd281f313 feat (schema): Add fetching default values for FIXED,
DECIMAL, TIME, TIMESTAMP, DATE, and UUID (#17892)
add e654914b3fea perf: Support mini-batch access to the MDT index for
bucket assign fu… (#17867)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/configuration/FlinkOptions.java | 10 +
.../apache/hudi/configuration/OptionsResolver.java | 8 +
.../hudi/sink/buffer/MemorySegmentPoolFactory.java | 5 +
.../sink/partitioner/BucketAssignFunction.java | 20 +-
.../partitioner/MiniBatchBucketAssignOperator.java | 74 +++++++
.../partitioner/MinibatchBucketAssignFunction.java | 167 +++++++++++++++
.../sink/partitioner/RecordIndexPartitioner.java | 76 +++++++
.../java/org/apache/hudi/sink/utils/Pipelines.java | 47 ++++-
.../TestMinibatchBucketAssignFunction.java | 227 +++++++++++++++++++++
.../partitioner/TestRecordIndexPartitioner.java | 107 ++++++++++
.../apache/hudi/table/ITTestHoodieDataSource.java | 20 ++
11 files changed, 743 insertions(+), 18 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/MiniBatchBucketAssignOperator.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/MinibatchBucketAssignFunction.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/RecordIndexPartitioner.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/partitioner/TestMinibatchBucketAssignFunction.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/partitioner/TestRecordIndexPartitioner.java
