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

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

操作过程

注册平台函数

  1. 登录 EasyStream实时计算平台
  2. 快捷导航栏 选择 UDF Studio ,若 快捷导航栏 中无相关选项可参考 快速导航栏 进行操作。
  3. 选择 资源管理 , 单击 上传资源 ,在弹出窗口中选择本地函数Jar进行上传,设定存储位置与可用范围。 UDF 管理 - 图1
  4. 单击 确定 ,保存资源。
  5. 选择 函数管理 ,单击 新建函数 ,在页面中选择 适用产品:实时计算,并完成其余表单信息的填写。
  6. 单击 确定 ,完成平台函数注册。

使用平台函数

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

使用用户自定义函数

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