Flink系列：Sink API使用方法

Flink自帶API writeAsText() 將元素以字符串形式逐行寫入，這些字符串通過調用每個元素的 toString()方法來獲取。   print() / printToErr() 打印每個元素的toString()方法的值到標準輸岀或者標準錯 誤輸出流中。 自定義輸出 addSink可以實現把數據輸出到第三方存儲介質中。 實現 SinkFunction 接口。 繼承 RichSinkF

>>阅读原文<<