状态类型
每个状态都是当前任务去管理维护,每个 状态 都是和当前 算子 关联在一起的,如果需要Flink真正的把他管理起来的话,在运行时的时候Flink就必须要知道当前状态定义的类型是什么,所以一开始必须注册对应的状态,要有所谓的描述器。
两种基本的状态:
Operator State算子状态Keyed State键控状态
区别
作用范围不一样
Operator State算子状态的作用范围,就是限定为算子任务(也就是当前一个分区执行的时候,所有数据来了都能访问到状态)Keyed State键控状态中并不是当前分区所有的数据都能访问所有的状态,而是按照keyby之后的key做划分,当前key只能访问自己的状态