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

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