Skip to content

Commit

Permalink
disable blob store
Browse files Browse the repository at this point in the history
  • Loading branch information
luizirber committed Dec 30, 2024
1 parent d3bb0d2 commit 2e0626b
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 0 additions & 2 deletions src/core/src/index/revindex/disk_revindex.rs
Original file line number Diff line number Diff line change
Expand Up @@ -86,8 +86,6 @@ impl RevIndex {

let db = Arc::new(DB::open_cf_descriptors(&opts, path, cfs).unwrap());

let processed_sigs = AtomicUsize::new(0);

let collection = Arc::new(collection);
let processed = Arc::new(RwLock::new(Self::load_processed(
db.clone(),
Expand Down
2 changes: 2 additions & 0 deletions src/core/src/storage/rocksdb.rs
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,7 @@ impl Storage for RocksDBStorage {
pub(crate) fn cf_descriptors(cache: rocksdb::Cache) -> Vec<ColumnFamilyDescriptor> {
let mut cfopts = db_options();

/*
// following https://rocksdb.org/blog/2021/05/26/integrated-blob-db.html
cfopts.set_enable_blob_files(true);
// If empty or one dataset, avoid saving to blob store
Expand All @@ -89,6 +90,7 @@ pub(crate) fn cf_descriptors(cache: rocksdb::Cache) -> Vec<ColumnFamilyDescripto
cfopts.set_blob_file_size(0x4000000); // 64 MiB
cfopts.set_enable_blob_gc(true);
cfopts.set_blob_compression_type(rocksdb::DBCompressionType::Zstd);
*/

cfopts.set_max_write_buffer_number(16);
cfopts.set_merge_operator_associative(
Expand Down

0 comments on commit 2e0626b

Please sign in to comment.