Flink- 键值分区状态 -10

1.键值分区状态

键值分区状态会按照输入算子记录所定义的键值来进行维护或访问，每个键值都维护一个状态实例，该实例总是位于那个处理对应键值记录的算子任务上。当任务在处理一个记录时，会自动把状态的访问范围限制为当前记录的键值。

所有键值相同的记录能访问到一样的状态。

2.键值分区状态 3 个状态

• 单值状态-value state : 每个键对应存储一个任意类型的值，该值也可以是某个复杂的数据结构

• 列表状态-list state：每个键对应存储一个值的列表，列表中的条目可以是任意类型。

• 映射状态-map state：每个键对应存储一个键值映射，该映射的键值可以是任意类型。

通过这些状态原语，可以为 Fink 状态指定不同的结构，从而实现更加高效的状态访问