我们使用侧输出流再来做一下那个高低温分流.这次我们使用
ProcessFunction来实现.
可以看到之前我们用split算子把一个流分成了多个流,然后这次我们利用ProcessFunction,
利用侧输出流来分流.
新建一个类ProcessTest3_SideOutputCase,这里我们用侧输出流实现分流
然后我们把创建环境,设置并行度,接收socket流
以及.map转换成SensorRea
时间:2024-01-06 15:20:11
我们使用侧输出流再来做一下那个高低温分流.这次我们使用
ProcessFunction来实现.
可以看到之前我们用split算子把一个流分成了多个流,然后这次我们利用ProcessFunction,
利用侧输出流来分流.
新建一个类ProcessTest3_SideOutputCase,这里我们用侧输出流实现分流
然后我们把创建环境,设置并行度,接收socket流
以及.map转换成SensorRea