Compaction
本章节仅适用于MRS 3.3.0及之后版本。
命令功能
对Hudi表进行compaction操作,具体作用可以参考Hudi Compaction操作说明章节。
命令格式
call run_compaction(op => '[op]', table=>'[table]', path=>'[path]', timestamp=>'[timestamp]');
参数描述
参数 |
描述 |
是否必填 |
---|---|---|
op |
生成compaction计划(op指定为“schedule”),或者执行已经生成的compaction计划(op指定为“run”) |
是 |
table |
需要查询表的表名,支持database.tablename格式 |
否 |
path |
需要查询表的路径 |
否 |
timestamp |
在op指定为“run”时,可以指定timestamp来执行该时间戳对应的compaction计划以及该时间戳之前未执行的compaction计划 |
否 |
示例
call run_compaction(table => 'hudi_table1', op => 'schedule'); call run_compaction(table => 'hudi_table1', op => 'run'); call run_compaction(table => 'hudi_table1', op => 'run', timestamp => 'xxx'); call run_compaction(path => '/user/hive/warehouse/hudi_table1', op => 'run', timestamp => 'xxx');
注意事项
compaction操作仅支持MOR表。
系统响应
可在客户端中查看查询结果。