当前位置:首页 > 编程笔记 > 正文
已解决

大数据Flink(一百零二):SQL 聚合函数(Aggregate Function)

来自网友在路上 174874提问 提问时间:2023-10-27 22:23:22阅读次数: 74

最佳答案 问答题库748位专家为你答疑解惑

文章目录

SQL 聚合函数(Aggregate Function)


SQL 聚合函数(Aggregate Function)

Python UDAF,即 Python AggregateFunction。Python UDAF 用来针对一组数据进行聚合运算,比如同一个 window 下的多条数据、或者同一个 key 下的多条数据等。针对同一组输入数据,Python AggregateFunction 产生一条输出数据。比如以下示例,定义了一个名字为 weighted_avg 的 Python UDAF:

from pyflink.common import Ro
查看全文

99%的人还看了

猜你感兴趣

版权申明

本文"大数据Flink(一百零二):SQL 聚合函数(Aggregate Function)":http://eshow365.cn/6-26355-0.html 内容来自互联网,请自行判断内容的正确性。如有侵权请联系我们,立即删除!