關於sink
下圖來自Flink官方，紅框中就是sink，可見實時數據從Source處開始，在Transformation階段完成業務邏輯後在sink結束，因此sink可以用來處理計算結果，例如控制檯輸出或者保存數據庫：
關於《Flink的sink實戰》系列文章
本文是《Flink的sink實戰》的第一篇，旨在初步瞭解sink，通過對基本API和addSink方法的分析研究，為後續的編碼實戰打好基礎；
從一段實例代碼開始
下面是個簡單的flink應用代碼，紅框中的
print方法就是sink操作：
下圖是官方給出的sink方式，都是DataStream類的API，直接調用即可實現sink，剛才代碼中的
print就是其中一個：
接下來看看上圖中API的源碼，先看
print方法，在DataStream.java中，如下，實際上是調用了addSink方法，入參是
PrintSinkFunction：
另一個常用API是writeAsText，源碼如下，調用了
writeUsingOutputFormat方法：
追蹤
writeUsingOutputFormat發現也是調用了addSink，入參是
OutputFormatSinkFunction：
print和writeAsText背後都在調用addSink，那麼另一個常用的
writeAsCsv方法呢？莫非也是調用addSink？打開一看果然，和writeAsText一樣調用了
writeUsingOutputFormat，而該方法裡面就是在調用addSink：
綜上所述，data sink的關鍵就是
addSink的入參，即
SinkFunction接口的實現，通過類圖直觀看到常見的sink能力是如何實現的：
從上圖可見抽象類
RichSinkFunction與各種sink能力的關係十分緊密，我們應該重點關注它，在類圖上展示方法簽名，如下圖：
如上圖所示，
RichSinkFunction本身沒有內容，但是它實現
SinkFunction，繼承
AbstractRichFunction，是
RichFunction和
SinkFunction這兩種特性的結合；
RichFunction的特性在前面的《Flink的DataSource三部曲》中已經瞭解，就是資源的open和close；
SinkFunction的特性呢？顯然是用來處理計算結果的，類圖上顯示的是兩個invoke方法，來看看官方的
PrintSinkFunction.java：
writer.write(record)的源碼在PrintSinkOutputWriter.java，如下所示：
小結
至此，我們已經對Flink的sink有了基本瞭解：
負責實時計算結果的處理(如輸出或持久化)；主要實現方式是調用DataStream.addSink方法；各種sink能力的實現，主要途徑是實現addSink方法的入參定義的接口；
後面的章節，一起進行sink方面的編碼實戰吧，實戰的方向：體驗官方提供的sink能力，自定義sink能力實現；