Flink学习笔记之六ProcessFunction

1.概念

低阶API process function，越底层越丰富复杂，提供了对状态的管理
中阶API DataStream API，一般都是使用这个
高级API SQL/Table API，高度抽象

屏幕快照 2019-03-21 下午12.02.35.png

2.onTimer

Process Function ,注册定时器，维护状态，定时到时触发调用onTimer

屏幕快照 2019-03-21 下午12.04.11.png

3.CoProcessFunction，双流操作

屏幕快照 2019-03-21 下午12.06.06.png

4.KeyedProcessFunction

，区别在于Context多了 getCurrentKey方法

屏幕快照 2019-03-21 下午12.06.22.png

5.TimerService

计时器不能太多，消耗性能

屏幕快照 2019-03-21 下午12.07.49.png