网站介绍:文章浏览阅读1k次,点赞2次,收藏2次。DataStream API Partion 部分操作Random partitioning:随机分区dataStream.shuffle()源码Rebalancing:对数据集进行再平衡,重分区,消除数据倾斜dataStream.rebalance()源码## Rescaling:Rescaling解释:举个例子:如果上游操作有2个并发,而下游操作有4个并发,那么上游的一..._flink partition规则
- 链接地址:https://blog.csdn.net/hongzhen91/article/details/90140385
- 链接标题:【05】Flink 之 DataStream API(三):Partition 操作_flink partition规则-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:3186
- 网站标签:flink partition规则