Flink物理分區及數據轉換

(1) 隨機分區(Random Partitioning) 隨機分到下游分區,分區相對均衡,但比較容易失去原有數據的分區結構 val shuffleStream = dataStream.shuffle (2) 平衡分區(Roundrobin Partitioning) 重分區,儘可能保證每個分區內的數量平衡 val shuffleStream = dataStream.rebalance() (

>>阅读原文<<