murr 0.2.1

Columnar in-memory cache for AI/ML inference workloads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

use rocksdb::{
    KeyEncodingType, MemtableFactory, Options, PlainTableFactoryOptions, SliceTransform,
};
use serde::{Deserialize, Serialize};

use crate::io::store::rocksdb::ReadMethod;

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
pub struct PlainConfig {
    #[serde(default = "default_bloom_bits")]
    pub bloom_bits_per_key: i32,
    /// PlainTable: hash table utilization ratio (lower = fewer collisions, more space).
    #[serde(default = "default_data_block_hash_ratio")]
    pub hash_table_ratio: f64,
    /// PlainTable: stride between sparse-index entries (lower = faster lookup, more memory).
    #[serde(default = "default_index_sparseness")]
    pub index_sparseness: usize,
    /// PlainTable: store the full index in the file instead of rebuilding at open.
    #[serde(default)]
    pub store_index_in_file: bool,
    #[serde(default)]
    pub huge_page_tlb_size: usize,
    #[serde(default = "default_write_buffer_size")]
    pub write_buffer_size: usize,
    #[serde(default = "default_target_file_size_base")]
    pub target_file_size_base: u64,
    #[serde(default = "default_disable_auto_compactions")]
    pub disable_auto_compactions: bool,
    #[serde(default = "default_plain_read_method")]
    pub read_method: ReadMethod,
    #[serde(default)]
    pub verify_checksums: bool,
}

impl Default for PlainConfig {
    fn default() -> Self {
        Self {
            bloom_bits_per_key: default_bloom_bits(),
            hash_table_ratio: default_data_block_hash_ratio(),
            index_sparseness: default_index_sparseness(),
            store_index_in_file: false,
            huge_page_tlb_size: 0,
            write_buffer_size: default_write_buffer_size(),
            target_file_size_base: default_target_file_size_base(),
            disable_auto_compactions: default_disable_auto_compactions(),
            read_method: default_plain_read_method(),
            verify_checksums: false,
        }
    }
}

fn default_plain_read_method() -> ReadMethod {
    ReadMethod::ParGet
}

fn default_bloom_bits() -> i32 {
    16
}
fn default_index_sparseness() -> usize {
    4
}
pub(super) fn default_data_block_hash_ratio() -> f64 {
    0.75
}
pub(super) fn default_write_buffer_size() -> usize {
    256 * 1024 * 1024
}
pub(super) fn default_target_file_size_base() -> u64 {
    1024 * 1024 * 1024
}
pub(super) fn default_disable_auto_compactions() -> bool {
    false
}

impl From<&PlainConfig> for Options {
    fn from(config: &PlainConfig) -> Self {
        let mut opts = Options::default();
        opts.create_if_missing(true);
        opts.create_missing_column_families(true);
        opts.set_allow_mmap_reads(true);
        opts.set_prefix_extractor(SliceTransform::create_noop());
        opts.set_memtable_factory(MemtableFactory::Vector);
        opts.set_write_buffer_size(config.write_buffer_size);
        opts.set_target_file_size_base(config.target_file_size_base);
        opts.set_disable_auto_compactions(config.disable_auto_compactions);
        opts.set_plain_table_factory(&PlainTableFactoryOptions {
            user_key_length: 0,
            bloom_bits_per_key: config.bloom_bits_per_key,
            hash_table_ratio: config.hash_table_ratio,
            index_sparseness: config.index_sparseness,
            huge_page_tlb_size: config.huge_page_tlb_size,
            encoding_type: KeyEncodingType::Plain,
            full_scan_mode: false,
            store_index_in_file: config.store_index_in_file,
        });
        opts
    }
}