This is an automated email from the ASF dual-hosted git repository.
akudinkin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 972408b55fc [HUDI-5251] Split GitHub actions CI by spark and flink
(#7265)
add 8d13a7e383c [HUDI-5023] Consuming records from Iterator directly
instead of using inner message queue (#7174)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/config/HoodieWriteConfig.java | 8 +-
.../table/action/commit/HoodieMergeHelper.java | 6 +-
...edExecutorFactory.java => ExecutorFactory.java} | 9 +-
.../hudi/execution/FlinkLazyInsertIterable.java | 7 +-
.../hudi/execution/JavaLazyInsertIterable.java | 6 +-
.../hudi/execution/SparkLazyInsertIterable.java | 6 +-
.../hudi/execution/TestSimpleExecutionInSpark.java | 242 +++++++++++++++++++++
.../util/queue/BaseHoodieQueueBasedExecutor.java | 4 +-
.../hudi/common/util/queue/ExecutorType.java | 10 +-
.../hudi/common/util/queue/HoodieExecutor.java | 6 +-
.../common/util/queue/SimpleHoodieExecutor.java | 92 ++++++++
.../benchmark/BoundInMemoryExecutorBenchmark.scala | 41 +++-
12 files changed, 404 insertions(+), 33 deletions(-)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/util/{QueueBasedExecutorFactory.java
=> ExecutorFactory.java} (88%)
create mode 100644
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestSimpleExecutionInSpark.java
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/queue/SimpleHoodieExecutor.java
