Flink 实践教程-进阶（9）：自定义表值函数（UDTF）原创

大家好，欢迎收看p linknk实战系列教程，本章节为进阶系列九自定义表值函数udtf的使用。腾讯云六计算AIST10大数据产品生态体系的实时化分析利器，兼容opalink作业。下面将教大家学习如何在ocean circle口作业里面使用自定义表值函数。本例子首先使用SQCDC连接器获取MYSQ数据，经过表值函数转换后存入MYSQ中。自定义表值函数可以实现将一行的数据转为多行，也可以实现一列转多列返回。首先，在本地的IDE中创建maven工程，编写jar作业、page p文件，添加必要的依赖项。接下来编写业务逻辑，这里定义一个表值函数。

这个函数可以将传入进来的某个字段使用某字符串进行分割后，分为两个字段返回，即实现一列转多列。紧接着使用打包命令打包，将jar包上传到O平台。进入ocean控制台，在依赖管理页面中将JA ball上传。然后进入moi sol控制台并登录。这里，作者提前创建好了两个表，一个表用于输出数据，另一个表用于接收数据。

进入ocean控制台，创建色口作业。点击开发调试，进入作业开发页面，单击作业参数，在引用程序包处引用刚刚上传的jar包。并根据引用的jar创建函数。然后创建source，单击插入模板，选择马口数据实时同步，点击添加修改数据源表的相关信息。接下来创建C，单击插入模板，选择JDBC数据目的表，点击添加修改目的表相关信息。

最后编写业务逻辑。这里我们将name字段切分成两个字段后存入马口。

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