Flink自带API

writeAsText()

将元素以字符串形式逐行写入，这些字符串通过调用每个元素的 toString()方法来获取。

print() / printToErr()

• 打印每个元素的toString()方法的值到标准输岀或者标准错 误输出流中。

自定义输出

addSink可以实现把数据输出到第三方存储介质中。

• 实现 SinkFunction 接口。
• 继承 RichSinkFunction 类。

Flink系列：自定义SinkFunction