函数管理

在FlinkSQL任务开发时，常需要借助函数对数据进行一些简单、快速、标准化的处理，不需要在每个任务中重复开发基础原始的计算逻辑，提升开发效率。

函数类别

• 系统函数：由平台内置的常见计算函数，如聚合函数、字符函数、日期函数、数学函数等。
• 自定义函数：由开发人员根据实际场景开发的自定义函数，可以上传至不同的目录下供本项目成员使用。
• 全局函数：租户内共享的自定义函数，同租户下其他项目可查看使用。

自定义函数

• 函数类型

  目前支持自定义创建UDF、UDTF、UDAF、Python UDF四种函数

• 创建流程

  流程如下：

  

  1. 本地开发调试，完成后打成JAR包
  2. 通过平台的【资源管理】，上传JAR包
  3. 在创建自定义函数时，选择对应JAR