大数据_Flink_Java版_数据处理_流处理API_Transform(4)_分流---Flink工作笔记0032

然后我们继续来看,上一节我们说了reduce的用法,然后现在我们要实现

分流的使用.

我们现在要对温度传感器的数据,温度大于35度的,放到一个流中输出,我们称为高温流

温度低于35度的,放到另一个流中输出,我们称为低温流.

可以看到,一个stream流,通过split可以分成两个流对吧,

一个stream1,一个stream2对吧.

 经过split分流以后的流还是一个DataStream对吧,然后,怎么把两个不同的流从这个DataStream中读取出来呢?