1.世界

2.概述

用户自定义函数是非常重要的一个特征，因为他极大地扩展了查询的表达能力。

在大多数场景下，用户自定义函数在使用之前是必须要注册的。对于Scala的Table API，udf是不需要注册的。
调用TableEnvironment的registerFunction()方法来实现注册。Udf注册成功之后，会被插入TableEnvironment的function catalog，这样table API和sql就能解析他了。
本文会主要讲三种udf：

ScalarFunction
TableFunction
AggregateFunction

3.Scalar Functions 标量函数

标量函数：是指指返回一个值的函数。标量函数是实现讲0，1，或者多个标量值转化为一个新值。

实现一个标量函数需要继承

95-910-144-源码-FlinkSQL-Flink的UDF相关推荐

95-070-040-源码-源码调试-FLINK源代码调试方式
1.视界 FLINK有两种比较好的调试方式第一种,直接通过IDEA WINDOWS调试前提是Flink所有依赖已经导入,直接在Test中打断点,然后直接Debug. 第二种,远程调试重复了:[f ...
从flink-example分析flink组件(3)WordCount 流式实战及源码分析
前面介绍了批量处理的WorkCount是如何执行的 <从flink-example分析flink组件(1)WordCount batch实战及源码分析> <从flink-exampl ...
Flink源码分析 - 源码构建
本篇文章首发于头条号Flink源码分析 - 源码构建,欢迎关注我的头条号和微信公众号"大数据技术和人工智能"(微信搜索bigdata_ai_tech)获取更多干货,也欢迎关注我的C ...
【FLink源码分析】：Accumulator源码分析
文章目录 Accumulator源码分析学习 Accumulator源码结构 Accumulator 结构成员方法 SimpleAccumulator 累加器使用案例 code Accumulato ...
Flink 全网最全资源（视频、博客、PPT、入门、原理、实战、性能调优、源码解析、问答等持续更新）
Flink 学习 https://github.com/zhisheng17/flink-learning 麻烦路过的各位亲给这个项目点个 star,太不易了,写了这么多,算是对我坚持下来的一种鼓励吧 ...
Flink 全网最全资源（视频、博客、PPT、入门、实战、源码解析、问答等持续更新）...
Flink 学习 github.com/zhisheng17/- 麻烦路过的各位亲给这个项目点个 star,太不易了,写了这么多,算是对我坚持下来的一种鼓励吧! 本项目结构博客 1.Flink 从0 ...
Flink 源码解析 —— 源码编译运行
更新一篇知识星球里面的源码分析文章,去年写的,周末自己录了个视频,大家看下效果好吗?如果好的话,后面补录发在知识星球里面的其他源码解析文章. 前言之前自己本地 clone 了 Flink 的源码,编 ...
Flink Cep 源码分析
复合事件处理(Complex Event Processing,CEP)是一种基于动态环境中事件流的分析技术,事件在这里通常是有意义的状态变化,通过分析事件间的关系,利用过滤.关联.聚合等技术,根据事 ...
【珍藏】 2012.NET开发必看资料53个+经典源码77个—下载目录
2019独角兽企业重金招聘Python工程师标准>>> .NET 是 Microsoft XML Web services 平台.XML Web services 允许应用程序通过I ...
Alink漫谈(十六) ：Word2Vec源码分析之建立霍夫曼树
Alink漫谈(十六) :Word2Vec源码分析之建立霍夫曼树文章目录 Alink漫谈(十六) :Word2Vec源码分析之建立霍夫曼树 0x00 摘要 0x01 背景概念 1.1 词向量 ...

95-910-144-源码-FlinkSQL-Flink的UDF

1.世界

2.概述

3.Scalar Functions 标量函数

95-910-144-源码-FlinkSQL-Flink的UDF相关推荐

最新文章

热门文章