Apache Flink 漫谈系列 - SQL概览

操作pageAccessSession_tab测试数据，我们按区域统计持续的两个会见用户之间的会见时距离断不高出3分钟的的页面会见量(PV).

SELECT 
region, 
SESSION_START(rowtime, INTERVAL '3' MINUTE) AS winStart, 
SESSION_END(rowtime, INTERVAL '3' MINUTE) AS winEnd, 
COUNT(region) AS pv 
FROM pageAccessSession_tab 
GROUP BY region, SESSION(rowtime, INTERVAL '3' MINUTE) 

d. Result

十二、UDX

Apache Flink 除了提供了大部门ANSI-SQL的焦点算子，也为用户提供了本身编写营业代码的机遇，那就是User-Defined Function,今朝支持如下三种 User-Defined Function：

• UDF - User-Defined Scalar Function
• UDTF - User-Defined Table Function
• UDAF - User-Defined Aggregate Funciton

UDX都是用户自界说的函数，那么Apache Flink框架为啥将自界说的函数分成三类呢?是按照什么分另外呢?Apache Flink对自界说函数举办分类的依据是按照函数语义的差异，函数的输入和输出差异来分类的，详细如下：

1. UDF

a. 界说

用户想本身编写一个字符串联接的UDF，我们只必要实现ScalarFunction#eval()要领即可，简质朴现如下：

object MyConnect extends ScalarFunction { 
@varargs 
def eval(args: String*): String = { 
val sb = new StringBuilder 
var i = 0 
while (i < args.length) { 
if (args(i) == null) { 
return null 
} 
sb.append(args(i)) 
i += 1 
} 
sb.toString 
}} 

b. 行使

... 
val fun = MyConnect 
tEnv.registerFunction("myConnect", fun) 
val sql = "SELECT myConnect(a, b) as str FROM tab" 
... 

2. UDTF

a. 界说

用户想本身编写一个字符串切分的UDTF，我们只必要实现TableFunction#eval()要领即可，简质朴现如下：

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!