Flink 自定义触发器实现带超时时间的 countAndTimeTrigger
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 自定义触发器实现带超时时间的 countAndTimeTrigger相关的知识，希望对你有一定的参考价值。
参考技术A 项目中需要自定义 trigger，需要基于两个条件：1. count 即 msg 的个数，当个数大于某个数时触发窗口 2. time 即每个固定的时间触发窗口以上是关于Flink 自定义触发器实现带超时时间的 countAndTimeTrigger的主要内容，如果未能解决你的问题，请参考以下文章