This is an automated email from the ASF dual-hosted git repository.
codope pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 06c8fa5a62f [HUDI-5294] Support type change for schema on read +
reconcile schema (#7326)
add 20eea46ca95 [HUDI-5023] Cleaning up `QueueBasedExecutor` impls (#7238)
No new revisions were added by this update.
Summary of changes:
.../hudi/execution/CopyOnWriteInsertHandler.java | 32 ++--
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 2 +-
.../action/bootstrap/BootstrapRecordConsumer.java | 11 +-
.../hudi/table/action/commit/BaseMergeHelper.java | 11 +-
.../hudi/util/QueueBasedExecutorFactory.java | 20 ++-
.../hudi/execution/ExplicitWriteHandler.java | 16 +-
.../hudi/execution/FlinkLazyInsertIterable.java | 19 +-
.../hudi/execution/JavaLazyInsertIterable.java | 16 +-
.../hudi/execution/SparkLazyInsertIterable.java | 4 +-
.../TestBoundedInMemoryExecutorInSpark.java | 55 +++---
.../hudi/execution/TestBoundedInMemoryQueue.java | 26 +--
.../execution/TestDisruptorExecutionInSpark.java | 20 +--
.../hudi/execution/TestDisruptorMessageQueue.java | 43 +++--
.../hudi/common/util/ParquetReaderIterator.java | 4 +-
.../util/queue/BaseHoodieQueueBasedExecutor.java | 193 +++++++++++++++++++++
.../common/util/queue/BoundedInMemoryExecutor.java | 122 ++-----------
...ueueIterable.java => BoundedInMemoryQueue.java} | 18 +-
.../hudi/common/util/queue/DisruptorExecutor.java | 97 ++---------
.../common/util/queue/DisruptorMessageQueue.java | 56 ++----
.../util/queue/FunctionBasedQueueProducer.java | 7 +-
.../hudi/common/util/queue/HoodieConsumer.java | 7 +-
.../hudi/common/util/queue/HoodieExecutor.java | 13 +-
.../hudi/common/util/queue/HoodieExecutorBase.java | 144 ---------------
.../util/queue/HoodieIterableMessageQueue.java | 29 ----
.../hudi/common/util/queue/HoodieMessageQueue.java | 11 ++
.../hudi/common/util/queue/HoodieProducer.java | 7 +-
.../util/queue/IteratorBasedQueueConsumer.java | 63 -------
.../util/queue/IteratorBasedQueueProducer.java | 9 +-
.../org/apache/hudi/table/format/FormatUtils.java | 68 ++++----
.../realtime/RealtimeUnmergedRecordReader.java | 81 +++++----
packaging/hudi-flink-bundle/pom.xml | 1 +
packaging/hudi-kafka-connect-bundle/pom.xml | 1 +
32 files changed, 509 insertions(+), 697 deletions(-)
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/queue/BaseHoodieQueueBasedExecutor.java
rename
hudi-common/src/main/java/org/apache/hudi/common/util/queue/{BoundedInMemoryQueueIterable.java
=> BoundedInMemoryQueue.java} (94%)
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieExecutorBase.java
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieIterableMessageQueue.java
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/queue/IteratorBasedQueueConsumer.java
