flinksql中怎么自定义udf
这期内容当中小编将会给大家带来有关flinksql 中怎么自定义udf,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
创新互联公司专注于网站建设,为客户提供网站制作、成都网站制作、网页设计开发服务,多年建网站服务经验,各类网站都可以开发,成都品牌网站建设,公司官网,公司展示网站,网站设计,建网站费用,建网站多少钱,价格优惠,收费合理。
1、pom.xml(注意:pom中有多余的jar,本人暂时未进行剔除)
4.0.0 org.example udf 1.0-SNAPSHOT 8 8 org.apache.flink flink-table-api-java-bridge_2.11 1.10.2 provided org.apache.flink flink-table-api-scala-bridge_2.11 1.10.2 provided org.apache.flink flink-table-planner_2.11 1.10.2 provided org.apache.flink flink-table-planner-blink_2.11 1.10.2 provided org.apache.flink flink-streaming-scala_2.11 1.10.2 provided org.apache.flink flink-table-common 1.10.2 provided
2、java代码:
package com.jd; import org.apache.flink.table.functions.ScalarFunction; public class HashCode extends ScalarFunction { public String eval(String s) { return "liuhaijing:"+s; } }
3、接下来就可以参照官网来使用了,配上截屏
上述就是小编为大家分享的flinksql 中怎么自定义udf了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。
分享文章:flinksql中怎么自定义udf
本文链接:http://scyanting.com/article/godiej.html