You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by xu...@apache.org on 2021/11/14 23:44:56 UTC

[hudi] branch master updated (c2f9094 -> 0bb6d8f)

This is an automated email from the ASF dual-hosted git repository.

xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from c2f9094  [HUDI-2756] Fix flink parquet writer decimal type conversion (#3988)
     add 0bb6d8f  [HUDI-2706] refactor spark-sql to make consistent with DataFrame api (#3936)

No new revisions were added by this update.

Summary of changes:
 .../common/model/DefaultHoodieRecordPayload.java   |   2 +-
 .../org/apache/hudi/HoodieSparkSqlWriter.scala     |  38 +---
 .../scala/org/apache/hudi/HoodieWriterUtils.scala  |  76 ++++++-
 .../apache/spark/sql/hudi/HoodieOptionConfig.scala |  73 +++++-
 .../org/apache/spark/sql/hudi/HoodieSqlUtils.scala |   2 +-
 .../spark/sql/hudi/analysis/HoodieAnalysis.scala   |   5 +-
 .../AlterHoodieTableAddColumnsCommand.scala        |   9 +-
 .../AlterHoodieTableDropPartitionCommand.scala     |   6 +-
 .../command/CreateHoodieTableAsSelectCommand.scala |   9 +-
 .../hudi/command/CreateHoodieTableCommand.scala    | 249 +++++++++++----------
 .../hudi/command/DeleteHoodieTableCommand.scala    |  21 +-
 .../command/InsertIntoHoodieTableCommand.scala     |  95 ++++----
 .../hudi/command/MergeIntoHoodieTableCommand.scala |  41 ++--
 .../hudi/command/UpdateHoodieTableCommand.scala    |  33 +--
 .../hudi-spark/src/test/java/HoodieJavaApp.java    |   2 +-
 .../src/test/resources/sql-statements.sql          |   4 +-
 .../apache/hudi/HoodieSparkSqlWriterSuite2.scala   |  47 ++++
 .../functional/TestDataSourceForBootstrap.scala    |   5 +-
 .../org/apache/spark/sql/hudi/TestAlterTable.scala |   4 +-
 .../sql/hudi/TestAlterTableDropPartition.scala     |   8 +-
 .../spark/sql/hudi/TestCompactionTable.scala       |   4 +-
 .../apache/spark/sql/hudi/TestCreateTable.scala    |  87 +++++--
 .../apache/spark/sql/hudi/TestDeleteTable.scala    |   2 +-
 .../spark/sql/hudi/TestHoodieOptionConfig.scala    | 184 +++++++++++++++
 .../apache/spark/sql/hudi/TestInsertTable.scala    |  43 ++--
 .../spark/sql/hudi/TestMergeIntoLogOnlyTable.scala |   2 +-
 .../apache/spark/sql/hudi/TestMergeIntoTable.scala |  22 +-
 .../spark/sql/hudi/TestMergeIntoTable2.scala       |  12 +-
 .../sql/hudi/TestPartialUpdateForMergeInto.scala   |   8 +-
 .../apache/spark/sql/hudi/TestShowPartitions.scala |   6 +-
 .../apache/spark/sql/hudi/TestUpdateTable.scala    |   2 +-
 31 files changed, 764 insertions(+), 337 deletions(-)
 create mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/HoodieSparkSqlWriterSuite2.scala
 create mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/TestHoodieOptionConfig.scala