当前位置:   article > 正文

flink的分区器策略_flink shufflepartitioner

flink shufflepartitioner

 

1.随机分区器 ShufflePartitioner

2.自定义分区器CustomPartitionerWrappery
使用用户定义的分区程序为每个元素选择目标任务。

3.全局分区器GlobalPartitioner

4.重行分区 RebalancePartitioner
分区元素轮循,从而为每个分区创建相等的负载。在存在数据偏斜的情况下对性能优化有用。

详细代码:

https://blog.csdn.net/huonan_123/article/details/104414396

 

另外一篇blog,提到了八大分区策略:

https://blog.csdn.net/wangpei1949/article/details/100631663?utm_medium=distribute.pc_relevant.none-task-blog-OPENSEARCH-1&depth_1-utm_source=distribute.pc_relevant.none-task-blog-OPENSEARCH-1

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Li_阴宅/article/detail/916443
推荐阅读
相关标签
  

闽ICP备14008679号