DataStream API使用Sink及自定义Sink

目录

Data Sinks  

案例

 自定义Sink

Human实体类

自定义RichSinkFunction 

MySQL Sink使用 

测试 

---

Data Sinks  

        数据接收器（Data sinks）消费数据流并将它们转发到文件、套接字、外部系统或打印它们。Flink带有各种内置输出格式，这些格式被封装在数据流的算子后面：

（1）writeAsText() / TextOutputFormat -将元素逐行写入字符串。通过调用每个元素的toString()方法获得string。

（2）writeAsCsv(…)/ CsvOutputFormat -将元组写入以逗号分隔的值文件。行和字段分隔符是可配置的。每个字段的值来自对象的toString()方法。

（3）print() / printToErr() -打印标准输出/标准错误流中每个元素的toString()值。可选地，可以提供一个前缀(msg)，它被附加到输出。这可以帮助区分不同的打印调用。如果并行度大于1，输出也将加上产生输出的任务的标识符。

（4）writeUsingOutputFormat() / FileOutputFormat -自定义文件输出的方法和基类。支持自定义对象到字节的转换。

（5）writeToSocket——根据SerializationSchema将元素写入套接字。

（6）addSink -调用自定义接收函数。Flink与其他系统(如Apache Kafka)的连接器捆绑在一起，这些系统被实现为接收函数。

        请注意，数据流上的write*()方法主要用于调试目的。它们不参与Flink的检查点，这意味着这些函数通常具有至少一次（at-least-once）的语义。将数据刷新到目标系统取决于OutputFormat的实现。这意味着并非发送到OutputFormat