分类 标签 存档 黑客派 订阅 搜索

flink 0 篇文章

flink 自定义触发器实现带超时时间的 CountWindow
flink 的 window 有两个基本款,TimeWindow 和 CountWindow。 TimeWindow 是到时间就触发窗口,CountWindow 是到数量就触发。 如果我需要到时间就触发,并且到时间之前如果已经积累了足够数量的数据;或者在限定时间内没有积累足够数量的数据,我依然希望触发窗口业务,那么就需要自定义触发器。
阅读更多