Flink StateBackend - DefaultOperatorStateBackend

December 2, 2019

由于目前已实现的 StateBackend 只对 KeyedStateBackend 进行了重写,所有的 Operator State 都会采用 DefaultOperatorStateBackend 进行 snapshot。

概览

DefaultOperatorStateBackend 状态主要分为两类:

  • PartitionableListState
  • BackendWritableBroadcastState

状态读写

状态快照

状态恢复