按键分区处理函数（KeyedProcessFunction）：先进行分区，然后定义处理操作 1.定时器（Timer）和定时服务（TimerService） 定时器（timers）是处理函数中进行时间相关操作的主要机制 定时服务（TimerService）提供了注册定时器的功能 TimerService 是 Flink 关于时间和定时器的基础服务接口： // 获取当前的处理时间 long currentProcessingTime(); // 获取当前的水位线（事件时间） long currentWatermark(); // 注册处理时间定时器，当处理时间超过 time 时触发 void registerProcessingTimeTimer(long time); // 注册事件时间定时器，当水位线超过 time 时触发 void registerEventTimeTimer(long time); // 删除触发时间为 time 的处理时间定时器 void deleteProcessingTimeTimer(long time); // 删除触发时间为 time...
