作者:让爱自由2009 | 来源:互联网 | 2023-06-28 20:33
然后我们继续来看,上一节我们说了reduce的用法,然后现在我们要实现分流的使用.我们现在要对温度传感器的数据,温度大于35度的,放到一个流中输出,我们称为高温流温度低于35度
然后我们继续来看,上一节我们说了reduce的用法,然后现在我们要实现
分流的使用.
我们现在要对温度传感器的数据,温度大于35度的,放到一个流中输出,我们称为高温流
温度低于35度的,放到另一个流中输出,我们称为低温流.
可以看到,一个stream流,通过split可以分成两个流对吧,
一个stream1,一个stream2对吧.
经过split分流以后的流还是一个DataStream对吧,然后,怎么把两个不同的流从这个DataStream中读取出来呢?