You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by si...@apache.org on 2021/08/15 00:20:39 UTC

[hudi] branch master updated (18e6b79 -> 23dca6c)

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 18e6b79  [MINOR] Adding back all old default val members to DataSourceOptions (#3474)
     add 23dca6c  [HUDI-2268] Add upgrade and downgrade to and from 0.9.0 (#3470)

No new revisions were added by this update.

Summary of changes:
 .../cli/commands/UpgradeOrDowngradeCommand.java    |  24 +--
 .../hudi/table/marker/DirectWriteMarkers.java      |  15 +-
 .../table/upgrade/AbstractUpgradeDowngrade.java    |  23 ++-
 .../table/upgrade/BaseOneToTwoUpgradeHandler.java  |  42 +++++
 .../upgrade/BaseOneToZeroDowngradeHandler.java}    |  22 ++-
 .../upgrade/BaseTwoToOneDowngradeHandler.java      | 142 ++++++++++++++
 .../upgrade/BaseZeroToOneUpgradeHandler.java}      |  40 ++--
 .../hudi/table/upgrade/DowngradeHandler.java       |   6 +-
 .../apache/hudi/table/upgrade/UpgradeHandler.java  |   6 +-
 .../hudi/table/upgrade/FlinkUpgradeDowngrade.java  |  14 +-
 .../table/upgrade/OneToTwoUpgradeHandler.java}     |  11 +-
 .../table/upgrade/OneToZeroDowngradeHandler.java   |  22 +--
 .../table/upgrade/TwoToOneDowngradeHandler.java}   |  15 +-
 .../table/upgrade/ZeroToOneUpgradeHandler.java     | 107 +----------
 .../table/upgrade/OneToTwoUpgradeHandler.java}     |  14 +-
 .../table/upgrade/OneToZeroDowngradeHandler.java   |  22 +--
 .../hudi/table/upgrade/SparkUpgradeDowngrade.java  |  15 +-
 .../table/upgrade/TwoToOneDowngradeHandler.java}   |  18 +-
 .../table/upgrade/ZeroToOneUpgradeHandler.java     | 107 +----------
 .../scala/org/apache/hudi/HoodieSparkUtils.scala   |  38 +++-
 .../hudi/table/upgrade/TestUpgradeDowngrade.java   | 209 ++++++++++++++++++---
 .../hudi/common/table/HoodieTableVersion.java      |   8 +-
 .../org/apache/hudi/common/util/MarkerUtils.java   |  11 +-
 .../org/apache/hudi/HoodieSparkSqlWriter.scala     |  10 +-
 .../scala/org/apache/hudi/HoodieWriterUtils.scala  |  22 +--
 .../service/handlers/marker/MarkerDirState.java    |   1 -
 .../hudi/utilities/deltastreamer/DeltaSync.java    |   7 +-
 27 files changed, 593 insertions(+), 378 deletions(-)
 create mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/BaseOneToTwoUpgradeHandler.java
 copy hudi-client/{hudi-flink-client/src/main/java/org/apache/hudi/table/upgrade/OneToZeroDowngradeHandler.java => hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/BaseOneToZeroDowngradeHandler.java} (72%)
 create mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/BaseTwoToOneDowngradeHandler.java
 copy hudi-client/{hudi-flink-client/src/main/java/org/apache/hudi/table/upgrade/ZeroToOneUpgradeHandler.java => hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/BaseZeroToOneUpgradeHandler.java} (79%)
 copy hudi-client/{hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/FullRecordBootstrapModeSelector.java => hudi-flink-client/src/main/java/org/apache/hudi/table/upgrade/OneToTwoUpgradeHandler.java} (72%)
 copy hudi-client/{hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaMergeOnReadTable.java => hudi-flink-client/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java} (66%)
 copy hudi-client/{hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/selector/MetadataOnlyBootstrapModeSelector.java => hudi-spark-client/src/main/java/org/apache/hudi/table/upgrade/OneToTwoUpgradeHandler.java} (69%)
 copy hudi-client/{hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaMergeOnReadTable.java => hudi-spark-client/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java} (66%)