You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by me...@apache.org on 2022/03/28 06:12:21 UTC
[hudi] branch master updated (d31cde2 -> 1d0f4cc)
This is an automated email from the ASF dual-hosted git repository.
mengtao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from d31cde2 [MINOR] Fix call command parser use spark3.2 (#5144)
add 1d0f4cc [HUDI-3538] Support Compaction Command Based on Call Procedure Command for Spark SQL (#4945)
No new revisions were added by this update.
Summary of changes:
.../hudi/command/CompactionHoodiePathCommand.scala | 92 +++----------
.../command/CompactionHoodieTableCommand.scala | 4 +-
.../command/CompactionShowHoodiePathCommand.scala | 31 ++---
.../command/CompactionShowHoodieTableCommand.scala | 1 +
.../command/procedures/HoodieProcedureUtils.scala | 33 +++--
.../hudi/command/procedures/HoodieProcedures.scala | 2 +
.../procedures/RunCompactionProcedure.scala | 144 +++++++++++++++++++++
...ocedure.scala => ShowCompactionProcedure.scala} | 41 ++++--
...ocedure.scala => TestClusteringProcedure.scala} | 3 +-
.../TestCompactionProcedure.scala} | 68 +++++-----
10 files changed, 266 insertions(+), 153 deletions(-)
copy hudi-common/src/main/java/org/apache/hudi/common/data/HoodieAccumulator.java => hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HoodieProcedureUtils.scala (54%)
create mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunCompactionProcedure.scala
copy hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/{ShowClusteringProcedure.scala => ShowCompactionProcedure.scala} (61%)
rename hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/{TestRunClusteringProcedure.scala => TestClusteringProcedure.scala} (99%)
copy hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/{TestCompactionTable.scala => procedure/TestCompactionProcedure.scala} (54%)