jjzjj

FLinkSQL

全部标签

FlinkSQL之Windowing TVF

WindowingTVF在Flink1.13版本之后出现的替代之前的Groupwindow的产物,官网描述其ismorepowerfulandeffective //TVF中的tumble滚动窗口 //tumble(tablesensor,descriptor(et),interval'5'second):作为一张表存在 //特别注意!!!! //如果在sql中使用了tumble窗口,则一定需要groupby,而且groupby后一定有window_start,window_end两个字段sql实现TVF的tumble窗口实现 packagenet.cyan.FlinkSql.TVF; ​ i