更新时间:2026-07-16 GMT+08:00
分享

初始化存量表的分区

命令功能

计算每个历史分区的最后修改时间,以“lastUpdateTime=最后修改时间”的格式将每个分区的最后修改时间写入每个分区下的“.hoodie_partition_metadata”文件中。TTL会依据“当前系统时间 - 分区最后修改时间”来判断每个分区是否老化。

命令格式

call ttl_update_partitions(table => "[table]", path => "[path]", dryRun => [dryRun])

参数描述

参数

描述

是否必填

table

用于指定需要初始化分区的Hudi表名称。String类型,表名或者库名.表名,和参数path二选一。

path

用于指定需要初始化分区的Hudi表的绝对路径。String类型,表的绝对路径,和参数table二选一。

dryRun

用于控制是否以试运行模式执行命令。Boolean类型,默认是false。

  • true:会打印出每个分区的最后修改时间,但不会把每个分区的最后修改时间写入每个分区下的“.hoodie_partition_metadata”文件中。
  • false:不仅会打印出每个分区的最后修改时间,而且会把每个分区的最后修改时间写入每个分区下的“.hoodie_partition_metadata”文件中。

示例

指定表名初始化TTL:

call ttl_update_partitions(table => "hudi_table", dryRun => true)

指定路径初始化TTL:

call ttl_update_partitions(path => "hdfs://hacluster/user/hive/warehouse/hudi_table/", dryRun => true)

相关文档