Function Specifications
When used as a Flink state backend, OmniStateStore and RocksDB both support core functions such as basic state read/write, checkpoints, and savepoints, providing a reference for evaluating the feasibility of replacing RocksDB with OmniStateStore.
Table 1 describes the comparison between RocksDB and OmniStateStore.
Item |
Function |
RocksDB State Backend |
OmniStateStore State Backend |
|---|---|---|---|
Basic status read and write APIs |
Operator state |
Supported |
Supported |
Broadcast state |
Supported |
Supported |
|
Value state |
Supported |
Supported |
|
List state |
Supported |
Supported |
|
Map state |
Supported |
Supported |
|
Reducing state |
Supported |
Supported |
|
Aggregating state |
Supported |
Supported |
|
Time to live (TTL) |
Supported |
Supported |
|
Timer |
Supported |
Supported |
|
Checkpoint |
Full snapshot |
Supported |
Supported |
Incremental snapshot |
Supported |
Supported |
|
Aligned snapshot |
Supported |
Supported |
|
Non-aligned snapshot |
Supported |
Supported |
|
Common snapshot restoration |
Supported |
Supported |
|
Snapshot restoration in scenarios with scaling parallelism |
Supported |
Supported |
|
Savepoint |
Hitless savepoint |
Supported |
Supported |
Blocking savepoint |
Supported |
Supported |
|
Standard savepoint |
Supported |
Supported |
|
Native savepoint |
Supported |
Supported |
|
Savepoint release |
Supported |
Supported |
|
Common savepoint restoration |
Supported |
Supported |
|
Savepoint restoration in scenarios with scaling parallelism |
Supported |
Supported |
|
Status data structure upgrade with savepoints |
Supported |
Supported |