福建省城乡和建设厅网站,p2p网站建设的步骤过程,专业上海网站建设公司排名,怎样做网站表白墙背景
在flink中#xff0c;我们经常使用ontimer计时器实现很多逻辑的功能#xff0c;常见的比如某个传感器温度增加连续超过1分钟的告警输出等#xff0c;本文就来简单记录下计时器的作用
计时器
ontimer的定义
public void onTimer(long timestamp, OnTimerContext ctx…背景
在flink中我们经常使用ontimer计时器实现很多逻辑的功能常见的比如某个传感器温度增加连续超过1分钟的告警输出等本文就来简单记录下计时器的作用
计时器
ontimer的定义
public void onTimer(long timestamp, OnTimerContext ctx, CollectorO out)timestamp: 触发定时器的事件/处理时间戳这个时间是register定时器时指定的那个时间 ctx 上下文对象通过它可以访问水位线时间戳处理时间时间戳当前键值等 out主输出注意ontimer定时器中也可以输出记录 基本上在定时器中我们能实现的逻辑和在process主逻辑中的一样
计时器局限性
我们只能在KeyedStream上也就是键值分区数据流上注册计时器如果你想要在DataStream上面使用你需要首先把DataStream转换成KeyedStream而转换的方式可以通过实现一个返回常数值的KeySelector来创建KeyedStream但是一旦这样做下游的算子的并行度相当于实际变成了1性能会受到极大的影响.
