点击上方蓝色字体，选择“设为星标”

回复”资源“获取更多资源

Flink 的 window 有两个基本款，TimeWindow 和 CountWindow。
TimeWindow 是到时间就触发窗口，CountWindow 是到数量就触发。

如果我需要到时间就触发，并且到时间之前如果已经积累了足够数量的数据；或者在限定时间内没有积累足够数量的数据，我依然希望触发窗口业务，那么就需要自定义触发器。

import org.apache.flink.api.common.functions.ReduceFunction;

使用示例（超时时间 10 秒，数据量上限 1000）：

stream

即可。

欢迎点赞+收藏+转发朋友圈素质三连

文章不错？点个【在看】吧！** 👇**

本文分享自微信公众号 - 大数据技术与架构（import_bigdata）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。