【05】Flink 之 DataStream API（三）：Partition 操做

一、Partition 操做經常使用API Random partitioning Rebalancing Rescaling Custom partitioning Broadcasting Random partitioning：隨機分區 使用dataStream.shuffle()方法 底層實現： public class ShufflePartitioner<T> extends Stre

>>阅读原文<<