UDF管理
更新时间: 2024-12-04 15:45:28
EasyStream 平台中可以使用的函数有两种:
- 第一种是由平台开发、注册和管理的内置函数,用户直接通过函数名使用即可。
- 第二种是用户自定义函数,由用户开发后先上传 Jar 包文件到平台,之后登记 UDF,即可在任务开发时使用。
操作过程
注册平台函数
- 登录 EasyStream实时计算平台 。
- 快捷导航栏 选择 UDF Studio ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
选择 资源管理 , 单击 上传资源 ,在弹出窗口中选择本地函数Jar进行上传,设定存储位置与可用范围。
- 单击 确定 ,保存资源。
- 选择 函数管理 ,单击 新建函数 ,在页面中选择 适用产品:实时计算,并完成其余表单信息的填写。
- 单击 确定 ,完成平台函数注册。
使用平台函数
- 快捷导航栏 选择 实时开发 ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
- 打开要使用函数的SQL任务标签页,选择左侧 UDF,展开函数列表。
- 选择目标函数,右键函数名并选择 复制函数名称。在代码中对应位置粘贴,并根据函数使用说明进行使用。
保存后,SQL代码自动解析 函数依赖,可展开右侧 依赖配置 查看。
使用用户自定义函数
- 快捷导航栏 选择 实时开发 ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
- 选择左侧 文件,上传本地函数Jar文件并保存至对应目录。
- 选择 开发,回到开发IDE页面,打开要使用函数的SQL任务标签页,输入如下语句进行使用。
其中,CREATE FUNCTION my_udf_func AS 'com.example.MyUDFClass'
my_udf_func
是自定义函数的名称,com.example.MyUDFClass
是实现该函数的 Java 类名。
目前仍推荐使用 UDF Studio 进行统一自定义函数的管理和使用,从而避免可能存在的类冲突等问题。