SAVE_POINT

命令功能

管理Hudi表的savepoint。

命令格式

• 创建savepoint：

  call create_savepoint('[table_name]', '[commit_Time]', '[user]', '[comments]');

• 查看所有存在的savepoint

  call show_savepoints(table =>'[table_name]');

• 回滚savepoint：

  call rollback_savepoint('[table_name]', '[commit_Time]');

参数描述

示例

call create_savepoint('hudi_test1', '20220908155421949');
call show_savepoint(table =>'hudi_test1');
call rollback_savepoint('hudi_test1', '20220908155421949');

注意事项

• MOR表不支持savepoint。
• 最大的savepoint之前的commit相关文件不会被clean。
• 存在多个savepoint时需要从最大的savepoint开始执行rollback，逻辑是：rollback savepoint -> delete savepoint -> rollback下一个savepoint。

系统响应

可在客户端中查看查询结果。