【Flink】【第五章 流处理API】传输算子

【Flink】【第五章 流处理API】传输算子 broadcast()

KeyBy

Shuffle

随机发往下游的subTask

Rebalance

轮询

forward

要求前后算子的并行度相同才可以用；一对一
rescala

按上游并行度个数划分下游并行度后，轮询

global

全部放进第一个分区

自定义分区方式