Flink 实践教程-进阶（8）：自定义标量函数（UDF）原创

大家好，欢迎收看patche winnk实战系列教程，本章节为进阶系列八、自定义标量函数的使用腾讯云六、计算LIST10大数据产品生态体系的实时化分析利器，兼容opachlink作业。下面将教大家学习如何在oist口作业里面使用udf函数。本例子首先使用data general连接器产生随机数据，经过udf函数转换后存入MYSQL。自定义标量函数可以将零个、一个或多个标量值映射到一个新的标量值。首先在本地的IDE中创建maven工程，编写Java jar作业。Page poem文件添加必要的依赖项。

接下来编写业务逻辑udf需要在scale function列中实现E方法。Open方法和close方法可选。这里定义一个获取字符串字段长度的udf函数，紧接着使用打包命令打包，将jar包上传到O平台。进入ocean控制台，在依赖管理页面中将JA ball上传。然后进入moql控制台并登录。

这里作者提前创建好了表，用于接收sin的数据。进入ocean控制台，创建色口作业。点击开发调试，进入作业开发页面，单击作业参数，在引用程序包处引用刚刚上传的jar包。并根据引用的jar创建udf函数。然后创建source，单击插入模板，选择data general虚拟数据源表，点击添加，修改数据源表的相关信息。

接下来创建C，单击插入模板，选择JDBC数据目的表，点击添加修改目的表相关信息。最后编写业务逻辑。这里我们计算两个字段的字符串长度和。

点击保存语法检查、发布草稿、运行作业。我们可以看到作业已经处于运行中状态，接下来返回马控制台查看刚刚写入的数据，到此为止，我们进阶系列八的演示就结束了，欢迎大家一元购体验流计算lchus。