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 4deaa30 [HUDI-2404] Add metrics-jmx to spark and flink bundles (#3632)
add b8dad62 [HUDI-2422] Adding rollback plan and rollback requested
instant (#3651)
No new revisions were added by this update.
Summary of changes:
.../hudi/client/AbstractHoodieWriteClient.java | 26 ++-
.../java/org/apache/hudi/table/HoodieTable.java | 21 ++
.../rollback/BaseRollbackActionExecutor.java | 108 +++++++---
.../table/action/rollback/BaseRollbackHelper.java | 217 ++++++++++++++++++++
.../rollback/BaseRollbackPlanActionExecutor.java | 131 ++++++++++++
.../CopyOnWriteRollbackActionExecutor.java | 21 +-
.../rollback/ListingBasedRollbackHelper.java | 227 ++++++---------------
.../rollback/ListingBasedRollbackStrategy.java | 76 +++++++
.../rollback/MarkerBasedRollbackStrategy.java | 144 ++++---------
.../MergeOnReadRollbackActionExecutor.java | 27 +--
.../hudi/table/action/rollback/RollbackUtils.java | 17 ++
.../SerializableHoodieRollbackRequest.java | 67 ++++++
.../client/common/HoodieFlinkEngineContext.java | 10 +
.../hudi/table/HoodieFlinkCopyOnWriteTable.java | 8 +
.../hudi/table/HoodieFlinkMergeOnReadTable.java | 8 +
.../table/upgrade/ZeroToOneUpgradeHandler.java | 9 +-
.../client/common/HoodieJavaEngineContext.java | 11 +
.../hudi/table/HoodieJavaCopyOnWriteTable.java | 8 +
.../client/common/HoodieSparkEngineContext.java | 7 +
.../hudi/table/HoodieSparkCopyOnWriteTable.java | 9 +
.../hudi/table/HoodieSparkMergeOnReadTable.java | 9 +
.../SparkCopyOnWriteRestoreActionExecutor.java | 13 +-
.../SparkMergeOnReadRestoreActionExecutor.java | 31 +--
.../table/upgrade/ZeroToOneUpgradeHandler.java | 7 +-
.../java/org/apache/hudi/table/TestCleaner.java | 4 +-
.../TestCopyOnWriteRollbackActionExecutor.java | 55 +++--
.../TestMergeOnReadRollbackActionExecutor.java | 18 +-
.../TestMarkerBasedRollbackStrategy.java | 21 +-
hudi-common/src/main/avro/HoodieRollbackPlan.avsc | 76 +++++++
.../hudi/common/engine/HoodieEngineContext.java | 4 +
.../common/engine/HoodieLocalEngineContext.java | 11 +
.../table/timeline/HoodieActiveTimeline.java | 45 +++-
.../hudi/common/table/timeline/HoodieInstant.java | 3 +-
.../hudi/common/table/timeline/HoodieTimeline.java | 5 +
.../table/timeline/TimelineMetadataUtils.java | 5 +
35 files changed, 1044 insertions(+), 415 deletions(-)
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackPlanActionExecutor.java
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/ListingBasedRollbackStrategy.java
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java
create mode 100644 hudi-common/src/main/avro/HoodieRollbackPlan.avsc
