Flink基础(69):FLINK SQL(46) 自定义函数(五)使用IntelliJ IDEA开发自定义函数
2021/8/7 19:08:04
本文主要是介绍Flink基础(69):FLINK SQL(46) 自定义函数(五)使用IntelliJ IDEA开发自定义函数,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
本文为您介绍如何使用IntelliJ IDEA开发实时计算Flink版自定义函数,包括搭建开发环境和实时计算Flink版作业中引用自定义函数。
背景信息
注意- 仅独享模式支持自定义函数功能。
- 请使用IntelliJ IDEA工具开发自定义函数。
配置Maven
Apache Maven 3.5.0 (ff8f5e7444045639af65f6095c62210b5713f426; 2017-04-04T03:39:06+08:00) Maven home: /Users/<userName>/Documents/maven/apache-maven-3.5.0 Java version: 1.8.0_121, vendor: Oracle Corporation Java home: /Library/Java/JavaVirtualMachines/jdk1.8.0_121.jdk/Contents/Home/jre Default locale: zh_CN, platform encoding: UTF-8 OS name: "mac os x", version: "10.12.6", arch: "x86_64", family: "mac"
搭建开发环境
实时计算Flink版作业引用JAR包
package com.hjc.test.blink.sql.udx; import org.apache.flink.table.functions.FunctionContext; import org.apache.flink.table.functions.ScalarFunction; public class StringLengthUdf extends ScalarFunction { // 可选,open方法可以不编写。 // 如果编写open方法,需要声明'import org.apache.flink.table.functions.FunctionContext;'。 @Override public void open(FunctionContext context) { } public long eval(String a) { return a == null ? 0 : a.length(); } public long eval(String b, String c) { return eval(b) + eval(c); } //可选,close方法可以不编写。 @Override public void close() { } }
这篇关于Flink基础(69):FLINK SQL(46) 自定义函数(五)使用IntelliJ IDEA开发自定义函数的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-10-06小米11i印度快充版ROM合集:极致体验,超越期待
- 2024-10-06【ROM下载】小米11i 5G 印度版系统, 疾速跃迁,定义新速度
- 2024-10-06【ROM下载】小米 11 青春活力版,青春无极限,活力全开
- 2024-10-05小米13T Pro系统合集:性能与摄影的极致融合,值得你升级的系统ROM
- 2024-10-01基于Python+Vue开发的医院门诊预约挂号系统
- 2024-10-01基于Python+Vue开发的旅游景区管理系统
- 2024-10-01RestfulAPI入门指南:打造简单易懂的API接口
- 2024-10-01初学者指南:了解和使用Server Action
- 2024-10-01Server Component入门指南:搭建与配置详解
- 2024-10-01React 中使用 useRequest 实现数据请求