功能规格
对比OmniStateStore与RocksDB作为Flink状态后端在基本状态读写、Checkpoint、Savepoint等核心功能上的支持情况,两者在功能点上均保持一致支持,为用户评估OmniStateStore替代RocksDB的可行性提供参考依据。
开源Flink使用的RocksDB状态后端功能与OmniStateStore功能对比详见表1。
功能分类 |
功能点 |
RocksDB StateBackend |
OmniStateStore StateBackend |
|---|---|---|---|
基本状态读写API |
Operator State |
支持 |
支持 |
Broadcast State |
支持 |
支持 |
|
Value State |
支持 |
支持 |
|
List State |
支持 |
支持 |
|
Map State |
支持 |
支持 |
|
Reducing State |
支持 |
支持 |
|
Aggregating State |
支持 |
支持 |
|
状态有效期(TTL) |
支持 |
支持 |
|
计时器(Timer) |
支持 |
支持 |
|
Checkpoint |
全量快照 |
支持 |
支持 |
增量快照 |
支持 |
支持 |
|
对齐快照 |
支持 |
支持 |
|
非对齐快照 |
支持 |
支持 |
|
普通快照恢复 |
支持 |
支持 |
|
扩缩并行度场景下快照恢复 |
支持 |
支持 |
|
Savepoint |
不停作业执行Savepoint |
支持 |
支持 |
停作业执行Savepoint |
支持 |
支持 |
|
标准格式Savepoint |
支持 |
支持 |
|
原生格式Savepoint |
支持 |
支持 |
|
删除Savepoint |
支持 |
支持 |
|
普通Savepoint恢复 |
支持 |
支持 |
|
扩缩并行度场景下Savepoint恢复 |
支持 |
支持 |
|
Savepoint支持状态数据结构升级 |
支持 |
支持 |
父主题: 相关参考