Savepoint

Savepoint简介

Savepoint用于保存并还原自定义的版本数据。

Hudi提供的Savepoint可以将不同的commit保存起来以便清理程序不会将其删除，后续可以使用Rollback进行恢复。

使用Savepoint

使用spark-sql管理savepoint。

示例如下：

• 创建savepoint

  call create_savepoints('hudi_test1', '20220908155421949');

• 查看所有存在的savepoint

  call show_savepoints(table =>'hudi_test1');

• 回滚savepoint

  call rollback_savepoints('hudi_test1', '20220908155421949');

savepoint的rollback与commit rollback相同，都必须从最新的instant逐个向前rollback。