add flush to rocksdb

This commit is contained in:
Jonathan de Jong 2021-12-16 21:48:12 +01:00
parent d7c8258641
commit c096eefa32

View file

@ -87,6 +87,8 @@ impl<'r> Segment for RocksDBCF<'r> {
self.db.rocks.put_cf(cf, key, value)?; self.db.rocks.put_cf(cf, key, value)?;
} }
self.db.rocks.flush_cf(cf)?;
Ok(()) Ok(())
} }