Flink函数管理
函数管理页面中，默认展示Flink页签。Flink函数管理中内置多种函数，也支持用户创建自定义函数。在创建作业时，可以根据需要选择不同的内置函数或自定义函数。
|
|
· 内置函数：系统事先已经定义好的函数，可以在SQL语句中直接使用。 · 自定义函数：为了实现内置函数不能够满足的场景需求而自己定义的函数，需要用户自行开发，可以参考Flink自定义函数开发。 |
Flink函数管理包括目录操作、函数中心、JAR包中心。Flink函数的基本操作流程如下：
用户可以参考Flink自定义函数开发中的样例开发自己需要的函数功能。
将开发好的代码以JAR包的形式上传至Flink函数管理中。
在Flink函数管理中，使用上传好的JAR包新建自定义函数。
在作业开发中即可在SQL语句里与调用内置函数一样直接调用自定义函数。
目录操作
在函数管理页面的目录区域中，用户可以在“Flink”页签的“自定义函数”目录下，创建子目录，以便于对用户自定义函数进行分类管理和查看。
在目录区域顶部的搜索框中，输入目录名称关键字，即可根据关键字模糊查询出对应目录。
“内置函数”目录用于归类系统内置的函数，此目录为系统目录，不支持新增、编辑、删除等操作。
“自定义函数”目录支持如下操作：
创建子目录：在函数管理页面目录区域的“Flink”页签中，将鼠标悬于“自定义函数”目录后的
图标上，在弹出菜单中选择[目录]菜单项。在输入框内输入子目录名称，并单击后方的
图标，子目录创建完成。
编辑子目录：在函数管理页面目录区域的“Flink”页签中，将鼠标悬于“自定义函数”目录下子目录后的
图标上，在弹出菜单中选择[编辑]菜单项。在输入框内输入子目录名称，并单击后方的
图标，子目录编辑完成。
删除子目录：在函数管理页面目录区域的“Flink”页签中，将鼠标悬于“自定义函数”目录下子目录后的
图标上，在弹出菜单中选择[删除]菜单项，并在弹出的删除确认对话框中，单击<确定>按钮，子目录删除完成。
|
|
自定义函数目录下只能创建一级子目录。 在新建自定义函数时（也即在函数中心注册自定义函数时），需要选择“自定义函数”目录的各子目录作为所在目录。 |
函数中心
函数中心用于管理用户创建的自定义函数及查看内置函数。
查看Flink函数列表
函数中心通过列表的形式展示了选定目录下的Flink函数，内置函数和自定义函数的列表不同。
内置函数列表包含了如下信息：
序号：函数在当前列表中的序号。
函数名：函数名称。
类型：函数的类型。
参数：函数中涉及的参数。
描述：函数的功能描述。
自定义函数列表包含了如下信息：
序号：函数在当前列表中的序号。
函数名：函数的名称。
所在JAR包：创建函数所选取的JAR包。
Class：函数的Class类。
描述：函数的描述信息。
更新时间：函数最后一次变更的时间。
操作：提供了可对自定义函数执行的操作链接。
列表的右上方提供了搜索功能，在搜索框中输入函数名称关键字，并点击后方的
图标，即可搜索出符合条件的函数。
新建函数
在函数管理页面目录区域的Flink页签中，选择“自定义函数”目录或其下任意子目录。
单击列表上方的<新建>按钮，弹出函数新建窗口。
在窗口中，配置函数参数，如下：
所属JAR包：在下拉框中选择上传的JAR包。
函数名称：配置函数名称。
所在目录：在下拉框中选择自定义子目录。
函数路径：在下拉框中选择函数路径。
函数描述：配置函数的描述信息。
点击
图标，可以重复配置函数参数，一次增加多个函数。点击
图标，可以去掉不需要的函数参数。
单击<确定>按钮，函数新建完成。
编辑函数
在“函数中心”页签的列表中，单击待编辑函数对应操作列中的“编辑”链接，弹出函数编辑窗口。
编辑函数相关的参数，参数说明请参见新建函数。
单击<确定>按钮，函数编辑完成。
删除函数
1. 删除单个函数
在“函数中心”页签的列表中，单击待删除函数对应操作列中的“删除”链接，弹出删除确认对话框。
单击<确定>按钮，函数删除完成。
2. 批量删除函数
在“函数中心”页签的列表中，勾选待删除函数左侧的复选框。
单击列表上方的<删除>按钮，弹出删除确认对话框。
单击<确定>按钮，函数批量删除完成。
JAR包中心
JAR包中心用于管理用户上传的JAR包。JAR包中包含了用户自定义的函数，可用于用户创建自定义函数。
在函数管理页面中，选择“JAR包中心”页签，即可进入JAR包中心。
查看JAR包列表
“JAR包中心”页签中，通过列表的方式展示了用户上传的JAR包。列表中包含如下信息：
序号：JAR包在当前列表中的序号。
JAR包名：JAR包的名称。
文件大小：JAR包的大小。
路径：JAR报的存放位置。
上传时间：用户上传JAR包的时间。
操作：提供了可对JAR包执行的操作。
JAR包列表的右上角提供了JAR包查询功能，在输入框中输入JAR包名称关键字，即可动态查询出符合条件的JAR包。
上传JAR包
|
|
实时计算服务要求所编写的JAR包使用的Open JDK版本最高为JDK1.8，请编写时注意Open JDK版本不要超过该版本。 |
在“JAR包中心”页签中，单击列表上方的<JAR包上传>按钮，弹出JAR包上传窗口。
单击<点击上传>按钮，在弹出窗口中选择准备好的JAR包。
单击<确定>按钮，JAR包上传操作完成。
更新JAR包
在“JAR包中心”页签的列表中，单击待更新JAR包对应操作列中的“更新”链接，弹出JAR包上传窗口。
单击<点击上传>按钮，在弹出窗口中选择准备好的新JAR包。
单击<确定>按钮，JAR包更新操作完成。
删除JAR包
1. 删除单个JAR包
在“JAR包中心”页签的列表中，单击待删除JAR包对应操作列中的“删除”链接，弹出删除确认对话框。
单击<确定>按钮，JAR包删除完成。
2. 批量删除JAR包
在“JAR包中心”页签的列表中，勾选待删除JAR包左侧的复选框。
单击列表上方的<删除>按钮，弹出删除确认对话框。