Flink 算子状态 -9

1.算子状态介绍



（1）作用域：算子状态作用域是某个算子任务

（2）并行任务的同一个算子可以访问到相同的状态

（3）不同任务之间不能访问算子状态，就是算子相同在不同任务之间也不能访问



2.Flink算子状态提供了3种原语



2.1 列表状态-list state

将状态表示为一个条目列表



2.2 联合列表状态-union list state

同样将状态表示为一个列表，但是在发生故障的时候，恢复方式与列表状态不同，有什么不同？后面会讲到



2.3 广播状态

（1）为了保证算子每个任务状态都相同的场景而设计

（2）将利用检查点或算子扩容，如何实现？后面会讲到