转换算子

转换算子的作用：将一条或者多条数据转换为一条新的数据

map

map作用:数据转换

实现

filter

作用：数据过滤

实现

flatMap

作用: 数据拆分，例如：一个List/Set 转换为多个数据

实现

聚合算子

作用: 数据合并

keyBy

作用: 基于每一条数据的key，对一条数据流中的数据进行数据分流，具有相同key的数据进入同一个数据流。keyBy是聚合的前置操作

实现

用户自定义转换算子

作用：根据用户的需要，实现转换算子的逻辑
分类：函数类，匿名函数，富函数类

h