温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
大家好,欢迎收看p flank实战系列教程,本章节为进阶系列时自定义聚合函数u daf的使用。腾讯云六计算AIST10大数据产品生态体系的实时化分析利器,兼容opalink作业。下面将教大家学习如何在oceansq作业里面使用自定义聚合函数。本例子首先使用MYQLCDC连接器获取sle数据,经过自定义聚合函数转换后存入Mo口中。自定义聚合函数udaf可以将多条记录聚合成一条记录。首先在本地的IDE中创建maven工程,编写jar作业。Page po文件添加必要的依赖项。接下来编写业务逻辑。
01:06
这里定义一个聚合函数,这个函数可以对输入进来的两个字段计算加权平均值。紧接着使用打包命令打包,将jar包上传到oist平台。进入ocean控制台,在依赖管理页面中将draw ball上传。然后进入Mo搜口控制台并登录。这里,作者提前创建好了两个表,一个表用于输出数据,另一个表用于接收数据。
02:07
进入ocean控制台,创建色口作业。点击开发调试,进入作业开发页面。单击作业参数,在引用程序包处引用刚刚上传的JA Bo。并根据引用的jar创建函数。然后创建source,单击插入模板,选择MYSQL数据实时同步,点击添加,修改数据源表的相关信息。
03:29
接下来创建,单击插入模板,选择JDBC数据目的表,点击添加修改目的表相关信息。
04:04
最后编写业务逻辑。这里我们计算value和we这两个字段的加权平均值。点击保存语法检查、发布草稿、运行作业。我们可以看到作业已经处于运行中状态,接下来返回master控制台查看刚刚写入的数据,到此为止,我们进阶系列时的演示就结束了,欢迎大家一元购体验流计算lchus。
我来说两句