Flink学习笔记之六ProcessFunction
2019-03-26 本文已影响0人
天火燎原_e548
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
