This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 4a9f826 [HUDI-3215] Solve UT for Spark 3.2 (#4565)
add 0bd38f2 [HUDI-2596] Make class names consistent in hudi-client (#4680)
No new revisions were added by this update.
Summary of changes:
.../hudi/cli/commands/TestRollbacksCommand.java | 4 +--
.../apache/hudi/async/AsyncClusteringService.java | 14 ++++----
.../org/apache/hudi/async/AsyncCompactService.java | 14 ++++----
.../apache/hudi/client/AsyncCleanerService.java | 6 ++--
...actClusteringClient.java => BaseClusterer.java} | 8 ++---
.../{AbstractCompactor.java => BaseCompactor.java} | 8 ++---
...ractHoodieClient.java => BaseHoodieClient.java} | 8 ++---
...WriteClient.java => BaseHoodieWriteClient.java} | 20 ++++++------
.../apache/hudi/client/CompactionAdminClient.java | 2 +-
.../java/org/apache/hudi/keygen/KeyGenUtils.java | 8 ++---
.../keygen/TimestampBasedAvroKeyGenerator.java | 8 ++---
...meParser.java => BaseHoodieDateTimeParser.java} | 4 +--
...meParserImpl.java => HoodieDateTimeParser.java} | 4 +--
.../metadata/HoodieBackedTableMetadataWriter.java | 6 ++--
.../hudi/metrics/MetricsReporterFactory.java | 10 +++---
.../CustomizableMetricsReporter.java} | 14 ++++----
.../AbstractUserDefinedMetricsReporter.java | 37 +++++++++-------------
...InsertHelper.java => BaseBulkInsertHelper.java} | 2 +-
.../action/commit/BaseCommitActionExecutor.java | 2 +-
...ractDeleteHelper.java => BaseDeleteHelper.java} | 2 +-
...stractMergeHelper.java => BaseMergeHelper.java} | 2 +-
...stractWriteHelper.java => BaseWriteHelper.java} | 2 +-
.../hudi/table/upgrade/DowngradeHandler.java | 4 +--
.../hudi/table/upgrade/OneToTwoUpgradeHandler.java | 2 +-
.../table/upgrade/OneToZeroDowngradeHandler.java | 2 +-
...deHelper.java => SupportsUpgradeDowngrade.java} | 2 +-
.../table/upgrade/ThreeToTwoDowngradeHandler.java | 2 +-
.../table/upgrade/TwoToOneDowngradeHandler.java | 2 +-
.../table/upgrade/TwoToThreeUpgradeHandler.java | 2 +-
.../hudi/table/upgrade/UpgradeDowngrade.java | 4 +--
.../apache/hudi/table/upgrade/UpgradeHandler.java | 4 +--
.../table/upgrade/ZeroToOneUpgradeHandler.java | 2 +-
.../hudi/metrics/TestMetricsReporterFactory.java | 8 ++---
.../providers/HoodieWriteClientProvider.java | 4 +--
.../apache/hudi/client/HoodieFlinkWriteClient.java | 2 +-
.../FlinkHoodieBackedTableMetadataWriter.java | 2 +-
.../table/action/commit/FlinkDeleteHelper.java | 2 +-
.../hudi/table/action/commit/FlinkMergeHelper.java | 2 +-
.../hudi/table/action/commit/FlinkWriteHelper.java | 2 +-
.../table/upgrade/FlinkUpgradeDowngradeHelper.java | 2 +-
.../apache/hudi/client/HoodieJavaWriteClient.java | 2 +-
.../table/action/commit/JavaBulkInsertHelper.java | 4 +--
.../hudi/table/action/commit/JavaDeleteHelper.java | 2 +-
.../hudi/table/action/commit/JavaMergeHelper.java | 2 +-
.../hudi/table/action/commit/JavaWriteHelper.java | 2 +-
.../hudi/async/SparkAsyncClusteringService.java | 8 ++---
.../hudi/async/SparkAsyncCompactService.java | 8 ++---
.../hudi/client/HoodieSparkClusteringClient.java | 4 +--
.../apache/hudi/client/HoodieSparkCompactor.java | 4 +--
.../apache/hudi/client/SparkRDDWriteClient.java | 2 +-
.../table/action/commit/SparkBulkInsertHelper.java | 4 +--
.../table/action/commit/SparkDeleteHelper.java | 4 +--
.../hudi/table/action/commit/SparkMergeHelper.java | 2 +-
.../hudi/table/action/commit/SparkWriteHelper.java | 4 +--
...ava => BaseSparkDeltaCommitActionExecutor.java} | 8 ++---
.../SparkBulkInsertDeltaCommitActionExecutor.java | 10 +++---
...BulkInsertPreppedDeltaCommitActionExecutor.java | 8 ++---
.../SparkDeleteDeltaCommitActionExecutor.java | 4 +--
.../SparkInsertDeltaCommitActionExecutor.java | 4 +--
...parkInsertPreppedDeltaCommitActionExecutor.java | 3 +-
.../SparkUpsertDeltaCommitActionExecutor.java | 4 +--
...parkUpsertPreppedDeltaCommitActionExecutor.java | 3 +-
.../table/upgrade/SparkUpgradeDowngradeHelper.java | 2 +-
.../functional/TestHoodieBackedMetadata.java | 2 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 4 +--
.../hudi/table/TestHoodieMergeOnReadTable.java | 4 +--
.../SparkStreamingAsyncClusteringService.java | 8 ++---
.../async/SparkStreamingAsyncCompactService.java | 8 ++---
68 files changed, 178 insertions(+), 181 deletions(-)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/{AbstractClusteringClient.java
=> BaseClusterer.java} (80%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/{AbstractCompactor.java
=> BaseCompactor.java} (78%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/{AbstractHoodieClient.java
=> BaseHoodieClient.java} (93%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/{AbstractHoodieWriteClient.java
=> BaseHoodieWriteClient.java} (98%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/parser/{AbstractHoodieDateTimeParser.java
=> BaseHoodieDateTimeParser.java} (94%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/parser/{HoodieDateTimeParserImpl.java
=> HoodieDateTimeParser.java} (96%)
copy
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/{userdefined/AbstractUserDefinedMetricsReporter.java
=> custom/CustomizableMetricsReporter.java} (81%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/{AbstractBulkInsertHelper.java
=> BaseBulkInsertHelper.java} (96%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/{AbstractDeleteHelper.java
=> BaseDeleteHelper.java} (95%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/{AbstractMergeHelper.java
=> BaseMergeHelper.java} (98%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/{AbstractWriteHelper.java
=> BaseWriteHelper.java} (97%)
rename
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/{BaseUpgradeDowngradeHelper.java
=> SupportsUpgradeDowngrade.java} (97%)
rename
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/{AbstractSparkDeltaCommitActionExecutor.java
=> BaseSparkDeltaCommitActionExecutor.java} (90%)
