Re: 关于时间窗口的问题

2022-01-09 文章 18703416...@163.com
你好,我理解你的意思了。 可以看下 flink-cep 相关内容, 利用模式匹配去实现 > 2022年1月8日 下午7:10,18765295...@163.com 写道: > > 您好: > 请教一个问题, > 例如:开启一个5秒钟的滚动窗口,当key001的两条数据进来时,没有满足时间触发,但是当key002的数据进来满足窗口触发条件,会将key001的两条数据输出出去。 > > 我想实现的是一个基于事件时间设置的滚动窗口,当key001的数据到来时,没有满足时间时,不会因为key002的数据到来触发key001的数据进行输出。 > 每个key都有一个属于自己的时间窗口,不会受其他

关于时间窗口的问题

2022-01-08 文章 18765295...@163.com
您好: 请教一个问题, 例如:开启一个5秒钟的滚动窗口,当key001的两条数据进来时,没有满足时间触发,但是当key002的数据进来满足窗口触发条件,会将key001的两条数据输出出去。 我想实现的是一个基于事件时间设置的滚动窗口,当key001的数据到来时,没有满足时间时,不会因为key002的数据到来触发key001的数据进行输出。 每个key都有一个属于自己的时间窗口,不会受其他分组key的影响,并且可以为每个key的时间窗口设置一个基于数量和时间的触发器,当满足数量时触发或者时间到了触发。 经过测试发现,现在设置的时间窗口里面会有不同key的数据在一起 每个分组是否有属于自己的