1.基本转换
#DataStream转换成DataStream
map()
filter()
flatMap()
2.键值对转换
#将DataStream转换成KeyedStream
keyBy()
#KeyedStream聚合函数
sum()
min()
max()
minBy()
maxBy()
reduce()
3.多流合并或单流拆分转换
#先进先出,不去重
union()
connect()
coMap()
coFlatMap()
#split是union的逆操作
split()
select()
4.分发转换
#随机数据交换
shuffle()
#轮流数据交换
rebalance()
#重调
rescale()
#广播
broadcast()
#全局
global()
二、设置并行度
setParallelism()