第一个场景: 从SQL的角度,增加时间字段精确到分钟为key,格式如yyyy-MM-dd HH:mm。这样是不是就可以实现你要到效果了。

flink小猪 <[email protected]> 于2020年3月27日周五 上午11:29写道:

> 我有两个需求
> 1.如果我需要开一个一分钟的窗口,但是我希望能够每5分钟输出一次结果(输出每分钟的聚合结果,即输出5行聚合结果),该怎么办?
> 2.如果我需要开一个一个小时的窗口,但是我希望能够每5分钟输出一次结果(窗口数据还没全部到达,先输出当前已经聚合的结果),该怎么办?



-- 
**************************************
 tivanli
**************************************

回复