第 07 篇：「RocksDB 深潜」—— 增量快照与 1.20 的文件合并

仓库：https://github.com/apache/flink
官方文档：https://nightlies.apache.org/flink/flink-docs-lts/
技术栈：Java 11 / RocksDB / LSM-Tree / SST / ColumnFamily / 增量快照 / FileMerging
解读版本：release-1.20.5（commit 0980485）
解读视角：总架构师评审（架构 / 源码 / 生产 / 进阶）

第 07 篇：「RocksDB 深潜」—— 增量快照与 1.20 的文件合并

阅读本文你将了解：

1. RocksDB 后端的六种状态 API 由 STATE_CREATE_FACTORIES 映射到 RocksDBValueState 等实现，底层是每个状态一个 ColumnFamily（flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:128）。
2. snapshot 先 writeBatchWrapper.flush() 把写批量刷进 db，

转载自 CSDN-专业IT技术社区

原文链接：https://blog.csdn.net/u010804586/article/details/164427476