flink1.12.x status状态管理-状态类型:Operator State、Keyed State

状态类型

每个状态都是当前任务去管理维护,每个 状态 都是和当前 算子 关联在一起的,如果需要Flink真正的把他管理起来的话,在运行时的时候Flink就必须要知道当前状态定义的类型是什么,所以一开始必须注册对应的状态,要有所谓的描述器。

两种基本的状态:

  • Operator State 算子状态

  • Keyed State 键控状态

区别

作用范围不一样

  • Operator State 算子状态的作用范围,就是限定为算子任务(也就是当前一个分区执行的时候,所有数据来了都能访问到状态)

  • Keyed State 键控状态中并不是当前分区所有的数据都能访问所有的状态,而是按照keyby之后的key做划分,当前key只能访问自己的状态