赞
踩
经过上面的 Transformation 操作之后,最终形成用户所需要的结果数据集。通常情况下,用户希望将结果数据输出到外部存储介质或者传输到下游的消息中间件中,在 Flink 中,将 DataStream 数据输出到外部系统的过程被定义为 Sink 操作。
目录
下面我们将通过使用 writeAsSocket() 的方式实验,完成 Sink 数据输出。
重写第二章《程序运行结构》中的案例,使用 writeAsSocket() 方式,通过统计 9999 端口输入的文本数量,将结果写入到 9998 端口的控制端。
1.修改第二章案例代码,具体
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。