补充下,是针对每个key,每1min输出一个结果。采用1h窗口,1min滑动窗口。



赵一旦 <[email protected]> 于2021年1月18日周一 下午3:51写道:

> 你貌似没懂我的意思。我的意思是你的需求和sliding window的效果应该就是一样的。
> 不是很清楚你表达的最早什么的是什么含义。
>
> 基于event time做sliding window,只要你没设置其他东西,就应该是1min输出一个结果而已哈。
>
> eriendeng <[email protected]> 于2021年1月18日周一 上午11:42写道:
>
>> 只要sliding出来才满足你每分钟执行的滑动要求吧?至于你只要最早/新的某一条,你可以从window groupby得出的流再次group
>> by然后再用window时间筛选你要的数据。
>>
>>
>>
>> --
>> Sent from: http://apache-flink.147419.n8.nabble.com/
>
>

回复