rocksdb相對于mysql等數(shù)據(jù)庫來說，比較小眾，即使接觸過一段時間flink后，還是會很好奇flink為啥要選擇rocksdb來做狀態(tài)存儲，這里總結(jié)一下為啥flink選擇rocksdb做狀態(tài)存儲的原因。
1.rocksdb采用的是LSM（Log-Struct Merge）結(jié)構(gòu)，對于LSM不了解的可以參考這篇文章：從B+樹到LSM樹，及LSM樹在HBase中的應用，LSM相對于mysql里面的B+樹來說，是寫更有優(yōu)勢，而讀則比不過B+樹，但是因為flink采用的keygroup的概念Flink 源碼：從 KeyGroup 到 Rescale，flink保存的keyedstate分散到每個算子的key其實有序的，而rocksdb存儲的每個key也是有序排列的，通過blomfilter和二分查找法來查詢數(shù)據(jù)。
2.rocksdb本身也是一種嵌入式數(shù)據(jù)庫，相對于flink的每個算子來說，每個算子的rocksdb可以理解成一個單獨的數(shù)據(jù)庫，他們之間不會存在讀寫并發(fā)的問題（因為針對每個算子來說，存儲的keyedstate中的key是不會有重復的）
3.rocksdb中memtable是insert或者delete的數(shù)據(jù)，每次備份的時候只需要備份memtable以及各個層級合并后新產(chǎn)生的文件，無需全部文件進行備份，flink的增量備份就是利用了rocksdb的這點特性就行增量備份的