- 基于flink-1.8.1
概述
- flink 流式計算中需要經(jīng)計算的結(jié)果進行輸出(可以是msyql/hbase/ES等常見的DB或者filesystem展辞,也可以是釘釘/郵件/短信等通知類信息)轴咱,官網(wǎng)上成為connector(連接器)酌摇。
-
flink內(nèi)置的連接器(官網(wǎng))如下龄捡,詳情可閱讀官網(wǎng):
flink中SinkFunction類關系
- flink中的的sink connector都是繼承的SinkFunction接口;
-
flink-1.8.1中源碼類之間的關系展示:
SinkFunction介紹
-
SinkFunction中的方法類
- 從上圖中可以看出践瓷,flink中自帶的 Sink 可以看到都是繼承了 RichSinkFunction 抽象類耕驰,實現(xiàn)了其中的方法;
- invoke方法中是執(zhí)行的sink操作既鞠;