100字范文,内容丰富有趣,生活中的好帮手!
100字范文 > 大数据_Flink_Java版_ProcessFunction(4)_应用案例_高低温分流---Flink工作笔记0069

大数据_Flink_Java版_ProcessFunction(4)_应用案例_高低温分流---Flink工作笔记0069

时间:2024-01-06 15:20:11

相关推荐

大数据_Flink_Java版_ProcessFunction(4)_应用案例_高低温分流---Flink工作笔记0069

我们使用侧输出流再来做一下那个高低温分流.这次我们使用

ProcessFunction来实现.

可以看到之前我们用split算子把一个流分成了多个流,然后这次我们利用ProcessFunction,

利用侧输出流来分流.

新建一个类ProcessTest3_SideOutputCase,这里我们用侧输出流实现分流

然后我们把创建环境,设置并行度,接收socket流

以及.map转换成SensorRea

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。