flink自定义trigger-实现窗口随意输出

前面，一篇简单讲了flink的窗口及与Spark Streaming窗口之间的对比。java 对于flink的窗口操做，尤为是基于事件时间的窗口操做，你们还要掌三个个重要的知识点：apache 窗口分配器：就是决定着流入flink的数据，该属于哪一个窗口。bootstrap 时间戳抽取器/watermark生成器：抽取时间戳并驱动着程序正常执行。windows trigger：决定着数据啥时候落地

>>阅读原文<<