本文重点
在前面的课程中,我们学习了Flink中的状态机制,本文我们来学习一下Flink中的状态类别。
状态类型
整理分为两类:
托管状态:算子状态和按键分区状态
原始状态
托管状态:
托管状态就是什么事情都有Flink来实现,比如故障恢复等问题,我们直接使用Flink为我们封装好的接口就可以了,安全放心。
托管状态又可以分为算子状态和按键分区状态两种,这是访问状态的两种方式。
原始状态:
原始状态就是我们自己来搞,Flink不会管我们,我们需要自己来做好状态管理和维护,一般情况下,不得已不要用原始状态。
算子状态
一个任务有两个并行子任务,那么这两个并行子任务将分别占用一个分区,状态是独立的,不会相互影响。对于每一个子任务而言,它所处理的所有事件元素都可以访问到相同的状态。