首页 > TAG信息列表 > TVF
flink--Window Aggregation【TVF 聚合 及 分组窗口聚合 】讲解及源码示例
1. 什么是Window TVF Aggregation Window TVF Aggregation 是指 基于应用Window TVF函数的分组统计,语法如下: SELECT ... FROM <windowed_table> -- relation applied windowing TVF GROUP BY window_start, window_end, ... 在GROUP BY子句中定义的窗口聚合包含应用于窗口TVflink--Window TVF【窗口化表值函数】讲解及源码示例
1. 什么是Window TVF Windowing TVFs: Flink定义的多态表函数(简称PTF),用于将表中的元素划分到定义的窗口中 窗口化TVFs替代了 legacy Grouped Window Functions。 windows TVFs更符合SQL标准,更强大的支持复杂的窗口计算,例如Window TopN, Window Join【在1.13.x中还不支持深入解读 Flink SQL 1.13版本新功能
一、Flink SQL 1.13 概览 Flink 1.13 是一个社区大版本,解决的 issue 在 1000 个以上,通过上图我们可以看到,解决的问题大部分是关于 Table/SQL 模块,一共 400 多个 issue 占了总体的 37% 左右。这些 issue 主要围绕了 5 个 FLIP 展开,在本文中我们也会根据这 5 个方面进行介绍,它们