事件时间的开窗问题

来源:8-8 【任务题】会话窗口编程

慕莱坞1153187

2021-12-24

您好,请问下基于EventTime的开窗,总是需要最新的一条数据来界定上一个时间窗口是否关闭,最后一条数据没办法参与聚合,这种问题一般怎么解决?
例如:时间窗口【0-10),来了一条数据时间为11,则会触发【0-10)的窗口进行聚合计算,而11这条数据由于窗口未关闭不会计算,而实际场景中,11这条数据是最后一条数据,也想在下个窗口关闭时进行计算。

写回答

1回答

Michael_PK

2021-12-29

明白你的意思了。

11这条数据本就不是【0-10),但是由于11触发了前面窗口的触发,11是只触发了,11这条数据不会参与到【0-10)这个窗口计算的。11的数据是要在下一个窗口被触发执行时,才会参与计算 

0
0

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车

1001 学习 · 225 问题

查看课程