Flink DataStream API之partition

Random partitioning：隨機分區java dataStream.shuffle()apache Rebalancing：對數據集進行再平衡，重分區，消除數據傾斜api dataStream.rebalance()併發 從源碼中關鍵代碼，可看出是partition的數據從新分配，以達到徹底的均衡dom import org.apache.flink.annotation.Intern

>>阅读原文<<