Cleaning

约束与限制

本章节仅适用于MRS 3.3.0-LTS及之后版本。

命令功能

对Hudi表进行cleaning操作，具体作用可以参考Hudi Cleaning操作说明章节。

命令格式

call run_clean(table=>'[table]', clean_policy=>'[clean_policy]', retain_commits=>'[retain_commits]', hours_retained=> '[hours_retained]', file_versions_retained=> '[file_versions_retained]');

参数描述

表1 参数描述
参数	描述	是否必填
table	需要查询表的表名，支持database.tablename格式	是
clean_policy	清理老版本数据文件的策略，默认KEEP_LATEST_COMMITS	否
retain_commits	仅对KEEP_LATEST_COMMITS策略有效	否
hours_retained	仅对KEEP_LATEST_BY_HOURS策略有效	否
file_version_retained	仅对KEEP_LATEST_FILE_VERSIONS策略有效	否

示例

call run_clean(table => 'hudi_table1');

call run_clean(table => 'hudi_table1', retain_commits => 2);

call run_clean(table => 'hudi_table1', clean_policy => 'KEEP_LATEST_FILE_VERSIONS', file_version_retained => 1);