Flink學(xué)習(xí)筆記之六ProcessFunction

1.概念

低階API process function，越底層越豐富復(fù)雜，提供了對(duì)狀態(tài)的管理
中階API DataStream API，一般都是使用這個(gè)
高級(jí)API SQL/Table API，高度抽象


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

2.onTimer

Process Function ,注冊(cè)定時(shí)器，維護(hù)狀態(tài)，定時(shí)到時(shí)觸發(fā)調(diào)用onTimer


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

3.CoProcessFunction，雙流操作

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

4.KeyedProcessFunction

，區(qū)別在于Context多了 getCurrentKey方法

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

5.TimerService

計(jì)時(shí)器不能太多，消耗性能


屏幕快照 2019-03-21 下午12.07.49.png
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容