更新时间:2022-09-30 GMT+08:00
分享

Savepoint

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

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

使用spark-sql管理savepoint。

示例如下:

  • 创建savepoint
    call create_savepoints('hudi_test1', '20220908155421949');
  • 查看所有存在的savepoint
    call show_savepoints(table =>'hudi_test1');
  • 回滚savepoint
    call rollback_savepoints('hudi_test1', '20220908155421949');

MoR表暂时不支持savepoint。

分享:

    相关文档

    相关产品