然后我们再来看,flink中对数据的处理,我们先看3个基本的转换算子,
其实就是把传过来的数据进行处理对吧.首先我们看这个
map算子.
map算子就是把一种格式,转换成另一种格式的数据.
然后我们再看flatMap这个算子,就是把原来的单个数据,
可以转换成多个数据.
然后再看filter这个算子,是可以对数据进行过滤的算子.
微信扫一扫
然后我们再来看,flink中对数据的处理,我们先看3个基本的转换算子,
其实就是把传过来的数据进行处理对吧.首先我们看这个
map算子.
map算子就是把一种格式,转换成另一种格式的数据.
然后我们再看flatMap这个算子,就是把原来的单个数据,
可以转换成多个数据.
然后再看filter这个算子,是可以对数据进行过滤的算子.
相关推荐