Flink State 扩容从新分配

参考学习博客而后写的学习笔记:算法 KeyedState - 这里面的key是咱们在SQL语句中对应的GroupBy/PartitioneBy里面的字段,key的值就是groupby/PartitionBy字段组成的Row的字节数组,每个key都有一个属于本身的State,key与key之间的State是不可见的; OperatorState - Apache Flink内部的Source Con
相关文章
相关标签/搜索