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

一、Partition 操做经常使用API Random partitioning Rebalancing Rescaling Custom partitioning Broadcasting Random partitioning：随机分区 使用dataStream.shuffle()方法 底层实现： public class ShufflePartitioner<T> extends Stre

>>阅读原文<<