flink定时器（Timer） 定时器（Timer）和定时服务（TimerService） 只有在 KeyedStream 中才支持使用 TimerService 设置定时器的 操作。所以一般情况下，我们都是先做了 keyBy 分区之后，再去定义处理操作；代码中更加常见的处理函数是 KeyedProcessFunction，最基本的 ProcessFunction 反而出镜率没那么高。 接下来我们就先从定时服务（TimerService）入手，详细讲解 KeyedProcessFunction 的用法。 KeyedProcessFunction 的一个特色，就是可以灵活地使用定时器。 定时器（timers）是处理函数中进行时间相关操作的主要机制。在.onTimer()方法中可以实 现定时处理的逻辑，而它能触发的前提，就是之前曾经注册过定时器、并且现在已经到了触发 时间。注册定时器的功能，是通过上下文中提供的“定时服务”（TimerService）来实现的。 TimerService 是 Flink 关于时间和定时器的基础服务接口，包含以下六个方法： // 获取当前的处理时间...
