Flink中上游DataStream到下游DataStream的内置分区策略及自定义分区策略

目录

全局分区器GlobalPartitioner

广播分区器BroadcastPartitioner

哈希分区器BinaryHashPartitioner

轮询分区器RebalancePartitioner

重缩放分区器RescalePartitioner

随机分区器ShufflePartitioner

转发分区器ForwardPartitioner

键组分区器KeyGroupStreamPartitioner

自定义分区器CustomPartitionerWrapper

---

        Flink提供了八种分区策略为上游DataStream中数据如何分发到下游DataStream中提供了分发策略。八种分发策略分别如下：

（1）全局分区器GlobalPartitioner

（2）广播分区器BroadcastPartitioner

（3）哈希分区器BinaryHashPartitioner

（4）重缩放分区器RescalePartitioner

（5）轮询分区器RebalancePartitioner

（6）随机分区器ShufflePartitioner

（7）转发分区器ForwardPartitioner

（8）键组分区器KeyGroupStreamPartitioner

（9）自定义分区器CustomPartitionerWrapper

        各个分区器的继承关系如下：

 各分区器的类定义如下：

// 流分区抽象类.
public abstract class StreamPartitioner<T> implements ChannelSelector<SerializationDelegate<StreamRecord<T>>>, Serializable// 全局分区类.
public class GlobalPartitioner<T>