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
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容