一:题目
Flink的keyby怎么实现的分区?分区、分组的区别是什么?
二:答案
Keyby实现原理:
对指定的key调用自身的hashCode方法=》hash1
调用murmruhash算法,进行第二次hash =》键组ID
通过一个公式,计算出当前数据应该去往哪个下游分区:
键组id * 下游算子并行度 / 最大并行度(默认128)文章来源:https://www.toymoban.com/news/detail-504059.html
分区:算子的一个并行实例可以理解成一个分区,是物理上的资源
分组:数据根据key进行区分,是一个逻辑上的划分
一个分区可以有多个分组,同一个分组的数据肯定在同一个分区文章来源地址https://www.toymoban.com/news/detail-504059.html
到了这里,关于07-Flink的keyby怎么实现的分区?分区、分组的区别是什么?的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!