This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 050f56aeb44 [HUDI-6505] Disabling a flaky test. Found 100+ invocations
of the test of interest (#9146)
add b98385369f1 [HUDI-6315] Optimize DELETE codepath to use meta fields
instead of key generation and index lookup (#8978)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/client/BaseHoodieWriteClient.java | 12 +++-
.../java/org/apache/hudi/index/HoodieIndex.java | 1 +
.../hudi/index/bucket/HoodieBucketIndex.java | 1 +
.../java/org/apache/hudi/table/HoodieTable.java | 15 +++-
.../storage/HoodieConsistentBucketLayout.java | 1 +
.../table/storage/HoodieSimpleBucketLayout.java | 1 +
.../apache/hudi/client/HoodieFlinkWriteClient.java | 9 +++
.../hudi/table/HoodieFlinkCopyOnWriteTable.java | 27 ++++++++
.../table/action/commit/FlinkDeleteHelper.java | 1 -
...=> FlinkDeletePreppedCommitActionExecutor.java} | 6 +-
.../apache/hudi/client/HoodieJavaWriteClient.java | 9 +++
.../hudi/table/HoodieJavaCopyOnWriteTable.java | 7 ++
.../hudi/table/action/commit/JavaDeleteHelper.java | 1 -
... => JavaDeletePreppedCommitActionExecutor.java} | 7 +-
.../apache/hudi/client/SparkRDDWriteClient.java | 9 +++
.../hudi/common/model/HoodieSparkRecord.java | 13 +++-
.../hudi/table/HoodieSparkCopyOnWriteTable.java | 6 ++
.../hudi/table/HoodieSparkMergeOnReadTable.java | 6 ++
...=> SparkDeletePreppedCommitActionExecutor.java} | 9 +--
...arkDeletePreppedDeltaCommitActionExecutor.java} | 6 +-
.../hudi/client/TestTableSchemaEvolution.java | 6 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 7 +-
.../TestHoodieClientOnMergeOnReadStorage.java | 6 +-
.../hudi/testutils/HoodieClientTestBase.java | 81 ++++++++++------------
.../hudi/common/model/WriteOperationType.java | 10 ++-
.../hudi/common/table/cdc/HoodieCDCExtractor.java | 2 +-
.../org/apache/hudi/sink/StreamWriteFunction.java | 1 +
.../main/java/org/apache/hudi/DataSourceUtils.java | 23 +++++-
.../org/apache/hudi/HoodieSparkRecordMerger.java | 30 ++++++--
.../scala/org/apache/hudi/DataSourceOptions.scala | 1 +
.../org/apache/hudi/HoodieCreateRecordUtils.scala | 4 +-
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 33 ++++++---
.../spark/sql/hudi/ProvidesHoodieConfig.scala | 3 -
.../hudi/command/DeleteHoodieTableCommand.scala | 9 ++-
.../apache/spark/sql/hudi/TestDeleteTable.scala | 45 ++++++++++++
35 files changed, 299 insertions(+), 109 deletions(-)
copy
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/{FlinkUpsertPreppedCommitActionExecutor.java
=> FlinkDeletePreppedCommitActionExecutor.java} (92%)
copy
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/{JavaInsertPreppedCommitActionExecutor.java
=> JavaDeletePreppedCommitActionExecutor.java} (92%)
copy
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/{SparkInsertPreppedCommitActionExecutor.java
=> SparkDeletePreppedCommitActionExecutor.java} (81%)
copy
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/{SparkInsertPreppedDeltaCommitActionExecutor.java
=> SparkDeletePreppedDeltaCommitActionExecutor.java} (92%)
