flink 自定义带超时时间的计数窗口触发器_counttriggerwithtimeout-CSDN博客

网站介绍:文章浏览阅读1.7k次,点赞2次,收藏3次。自定义带超时时间的计数窗口触发器import org.apache.flink.api.common.functions.ReduceFunction;import org.apache.flink.api.common.state.ReducingState;import org.apache.flink.api.common.state.ReducingStateDescriptor;import org.apache.flink.api.common.typeutils.base.LongSe_counttriggerwithtimeout