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

前面，一篇简单讲了flink的窗口及与Spark Streaming窗口之间的对比。 对于flink的窗口操作，尤其是基于事件时间的窗口操作，大家还要掌三个个重要的知识点： 窗口分配器：就是决定着流入flink的数据，该属于哪个窗口。 时间戳抽取器/watermark生成器：抽取时间戳并驱动着程序正常执行。 trigger：决定着数据啥时候落地。 flink有很多内置的触发器，对于基于事件时间的窗

>>阅读原文<<