本文共 297 字,大约阅读时间需要 1 分钟。
手动分区,手动设置分区和指定value作为分区
dataStream.partitionCustom(partitioner, "someKey");
随机分区
dataStream.shuffle();
round-robin,负载均衡,均匀分布
dataStream.rebalance();
均匀分发到同一chain的下游
dataStream.rescale();
广播到下游,每个算子都会得到所有的值
dataStream.broadcast();
转载地址:http://gougf.baihongyu.com/