1.視界

2.前文回顧
AbstractUdfStreamOperator 是繼承AbstractStreamOperator的抽象實作類,其内部包含了userFunction, 在Task的生命周期都會調用userFunction中對應的方法;
AbstractUdfStreamOperator繼承了AbstractStreamOperator,對其部分方法做了增強,多了一個成員變量UserFunction,并提供get方法。此外還實作了OutputTypeConfigurable接口的setOutputType方法對輸出資料的類型做了設定。
- 還是算子生命周期相關的方法:首先調用了前文提到的AbstractStreamOperator相應方法,然後為userFunction提供runtimeContext,Configuration,并且調用function的open和close方法。
- 狀态和checkpoint相關的方法: 首先調用父類相應方法,完成算子狀态的别分與恢複,然後調用實作了Checkpoint相關的接口的userFunction的相關方法。
#3.拓撲圖
[外鍊圖檔轉存失敗,源站可能有防盜鍊機制,建議将圖檔儲存下來直接上傳(img-F1YqVaNn-1588159712250)(00-flink/image-