数据仓库服务 GAUSSDB(DWS)-Hudi系统函数:hudi_sync_task_submit(regclass, regclass, text, text)

时间:2024-10-21 16:50:42

hudi_sync_task_submit(regclass, regclass, text, text)

描述:功能与hudi_sync_task_submit(regclass, regclass)一致,不同之处在于,用户可以额外指定两个text入参,表示用户期望哪些字段被同步。字段之间使用','分隔,支持引号和转义字符的解析。两个text参数的字段数量和顺序应当一致,表示同步字段之间的对应关系。提交任务成功会返回任务的task-id。

返回值类型:text

  • 同步目标表必须包含主键,且主键需要与hudi recordkey一致。
  • 如果hudi表包含precombine字段,那么同步目标表也必须包含与之对应的字段。
  • 如果同步目标表只包含主键(除了主键外没有其他字段),则无法正常提交同步任务。
  • 用户需要有同步目标表的insert和update权限、HUDI外表的select权限,否则无法正常提交同步任务。

示例:

1
2
3
4
5
SELECT hudi_sync_task_submit('public.hudi_sync_i','public.hudi_mor_ft','_hoodie_commit_time, col_bigint, col_text', '_hoodie_commit_time, col_bigint, col_text');
        hudi_sync_task_submit
--------------------------------------
 646610bc-cdd1-0d00-d07d-b57e89a0fffe
(1 row)
support.huaweicloud.com/sqlreference-830-dws/dws_06_0359.html