Shulou(Shulou.com)06/02 Report--

In this issue, Xiaobian will bring you about how to customize udf in flinksql. The article is rich in content and analyzed and described from a professional perspective. After reading this article, I hope you can gain something.

1. pom.xml (Note: There are redundant jars in pom, which I have not eliminated for the time being)

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 code:

package com.jd;import org.apache.flink.table.functions.ScalarFunction;public class HashCode extends ScalarFunction { public String eval(String s) { return "liuhaijing:"+s; }}

3. Next, you can refer to the official website to use it, with screenshots.

The above is how to customize udf in flinksql shared by Xiaobian. If there is a similar doubt, please refer to the above analysis for understanding. If you want to know more about it, please pay attention to the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.