flink底層API:KeyedProcessFunction


KeyedSteam可以調用process方法, 該方法可以接受一個KeyedProcessFunction類型的參數. 

KeyedProcessFunction類型的上層 父類是RichFunction, 對分流后每一個元素調用一次KeyedProcessFunction中的elementProcess方法,可以通過Context調用timeServier, 注冊定時器, 獲得當前水位線, 處理時間, 等信息.


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM