EasyStream 平台中可以使用的函数有两种:

  • 第一种是由平台开发、注册和管理的内置函数,用户直接通过函数名使用即可。
  • 第二种是用户自定义函数,由用户开发后先上传 Jar 包文件到平台,之后登记 UDF,即可在任务开发时使用。

操作过程

注册平台函数

  1. 登录 EasyStream实时计算平台
  2. 快捷导航栏 选择 UDF Studio ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
  3. 选择 资源管理 , 单击 上传资源 ,在弹出窗口中选择本地函数Jar进行上传,设定存储位置与可用范围。

  4. 单击 确定 ,保存资源。
  5. 选择 函数管理 ,单击 新建函数 ,在页面中选择 适用产品:实时计算,并完成其余表单信息的填写。
  6. 单击 确定 ,完成平台函数注册。

使用平台函数

  1. 快捷导航栏 选择 实时开发 ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
  2. 打开要使用函数的SQL任务标签页,选择左侧 UDF,展开函数列表。
  3. 选择目标函数,右键函数名并选择 复制函数名称。在代码中对应位置粘贴,并根据函数使用说明进行使用。
  4. 保存后,SQL代码自动解析 函数依赖,可展开右侧 依赖配置 查看。

使用用户自定义函数

  1. 快捷导航栏 选择 实时开发 ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
  2. 选择左侧 文件,上传本地函数Jar文件并保存至对应目录。
  3. 选择 开发,回到开发IDE页面,打开要使用函数的SQL任务标签页,输入如下语句进行使用。
    CREATE FUNCTION my_udf_func AS 'com.example.MyUDFClass'
    其中,my_udf_func 是自定义函数的名称,com.example.MyUDFClass 是实现该函数的 Java 类名。

目前仍推荐使用 UDF Studio 进行统一自定义函数的管理和使用,从而避免可能存在的类冲突等问题。