Flink应用开发系列（二十八）DataStream开发之系统自带的sink

在datastream api的应用程序开发中，除了系统自带的source之外，系统还自带一些sink，本文的话，我们就介绍下系统自带的sink。

1）writeAsText()

 将元素以字符串的形式写入文本文件。示例代码如下：

dataStream.writeAsText("hdfs://192.168.31.218:9000/out");

2）writeAsCsv()

将元素写成以逗号分隔的csv格式的文件。示例代码如下：

dataStream.writeAsCsv("hdfs://192.168.31.218:9000/out.csv");

3）print()

将元素打印到控制台上，示例代码如下：

dataStream.print()

4）writeToSocket()

把元素写入socket流中，示例代码如下：

dataStream.writeToSocket("192.168.31.218",9999,new SimpleStringSchema());

以上就是常用的系统自带的sink，当然在实际应用中，我们大部分场景都会自定义sink，所以直接使用addSink即可。下一篇文章我们会介绍关于自定义sink的案例。