阿里云轻应用服务器 建设网站,中国最大的建材网站,太原首页推广,手机主题制作软件目录
Data Sinks
案例 自定义Sink
Human实体类
自定义RichSinkFunction
MySQL Sink使用
测试 Data Sinks 数据接收器（Data sinks）消费数据流并将它们转发到文件、套接字、外部系统或打印它们。Flink带有各种内置输出格式，这些格式被封装在数据流的算子后面：
…目录
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
