【05】Flink 之 DataStream API(三):Partition 操作_flink partition规则-CSDN博客

网站介绍:文章浏览阅读1k次,点赞2次,收藏2次。DataStream API Partion 部分操作Random partitioning:随机分区dataStream.shuffle()源码Rebalancing:对数据集进行再平衡,重分区,消除数据倾斜dataStream.rebalance()源码## Rescaling:Rescaling解释:举个例子:如果上游操作有2个并发,而下游操作有4个并发,那么上游的一..._flink partition规则