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]', '[savepoint_Time]');

参数描述

表1 参数描述
参数	描述	是否必填
table_name	需要查询的表名，支持database.tablename格式。	是
commit_Time	指定创建或回滚的时间戳。	是
user	创建savepoint的用户。	否
comments	该条savepoint的注释说明。	否
savepoint_Time	创建savepoint的时间戳	是

示例

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

注意事项

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