网站开发的几个步骤安丘住房建设局网站

经过上面的 Transformation 操作之后，最终形成用户所需要的结果数据集。通常情况下，用户希望将结果数据输出到外部存储介质或者传输到下游的消息中间件中，在 Flink 中，将 DataStream 数据输出到外部系统的过程被定义为 Sink 操作。

目录

（一）基本数据输出

（二）第三方数据输出

（三）自定义输出

（一）基本数据输出

• writeAsText( ) ：将元素转为 String 类型按行写入外部输出。
• writeAsSocket( ) ：将元素写入 Socket
• writeAsCsv( ) ：将元素写入文本

下面我们将通过使用 writeAsSocket() 的方式实验，完成 Sink 数据输出。

重写第二章《程序运行结构》中的案例，使用 writeAsSocket() 方式，通过统计 9999 端口输入的文本数量，将结果写入到 9998 端口的控制端。

1.修改第二章案例代码，具体