Flink 入门（十） ——窗口
时间概念
事件时间、处理时间与进入时间（进入处理系统的时间)。
有些程序（如预警程序）允许小的误差（事件迟到），并且希望尽快得到结果，考虑使用处理时间语义。
欺诈检测系统或账单系统对准确性要求高，只有在时间窗口内发生的事件才能被算进来，考虑使用事件时间语义。
窗口
1.时间窗口
时间窗口是最简单和最有用的一种窗口。它支持滚动 Tumbling 与滑动 Sliding。
2.计数窗口
3.会话窗口
会话指的是活动阶段，其前后都是非活动阶段，例如用户与网站进行一系列 交互（活动阶段）之后，关闭浏览器或者不再交互（非活动阶段）。会话需要有自己的处理机制，因为它们通常没有固定的持续时间（有些 30 秒就结 束了，有些则长达一小时），或者没有固定的交互次数（有些可能是 3 次点击后购买，另一些可能是 40 次点击却没有购买）。flink 中会话由超时间设定，即希望多久才认为会话已结束。
窗口组件
1.WindowAssigner
为数据分配窗口。assignWindows
方法定义返回的结果是一个集合，数据可以被分配到多个窗口中。
1 文章转载自逗先生大数据，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。 评论 |
