在 SQL 任务开发中,如果系统预置的内部函数无法满足业务需求时,可以选择创建自定义函数解决问题。
UDF(User Defined Function)函数,即用户自定义函数。
系统已经内置了SUBSTRING
、REPLACE
等字符串操作函数,以及MAX
、MIN
、AVG
等聚合函数;但是内置函数也会出现无法支撑现实业务的时候,此时您可以选择自行编写代码逻辑来创建自定义函数,从而实现现实业务。
您在创建 UDF 函数前,请自行完成编写代码,并构建 JAR 包。
在顶部菜单栏选择目标地域。
在左侧导航栏选择项目管理,然后单击项目卡片进入项目。
在项目左侧导航栏选择任务开发 > Jupyter lab,然后单击函数栏目,再单击创建函数的加号按钮。
在创建函数对话框,设置自定义函数关键参数,然后单击确定。
配置 | 说明 |
---|---|
创建类型 | 根据实际需求选择 Flink 函数类型。
|
函数名称 | 自定义设置函数名称。 |
所属数据库 | 从下拉列表中选择目标元数据库。如果还未创建元数据库,请参见管理元数据。 |
函数类名 | 与您即将上传的 JAR 文件中的类名保持一致。 |
输入参数 | 输入函数的入参。 |
输出参数 | 输入函数的出参。 |
资源上传 | 上传您的 UDF JAR 文件。 |
创建自定义函数后,支持您下载自定义函数文件和删除自定义函数。