Flink物理分区及数据转换

(1) 随机分区(Random Partitioning) 随机分到下游分区,分区相对均衡,但比较容易失去原有数据的分区结构 val shuffleStream = dataStream.shuffle (2) 平衡分区(Roundrobin Partitioning) 重分区,尽可能保证每个分区内的数量平衡 val shuffleStream = dataStream.rebalance() (

>>阅读原文<<