Struct SstFileBuffer 

pub struct SstFileBuffer<K, V> { /* private fields */ }

Rows of one table, held in memory until Self::write_file writes them, sorted, to an SST file for DBMap::ingest_sst_files.

Writing rows this way bypasses the memtables, which RocksDB flushes one at a time per column family, so many threads can each fill their own files at once. Keys and values are encoded as DBMap encodes them.

Implementations

impl<K: Serialize, V: Serialize> SstFileBuffer<K, V>

pub fn new() -> Self

pub fn insert(&mut self, key: &K, value: &V) -> Result<(), TypedStoreError>

pub fn is_empty(&self) -> bool

pub fn size_in_bytes(&self) -> usize

The memory the buffered rows take.

pub fn write_file( &mut self, path: &Path, options: &Options, ) -> Result<(), TypedStoreError>

Writes the buffered rows, sorted by key, to a new SST file at path and empties the buffer. A key inserted more than once keeps its last value.

options must be those of the column family the file is ingested into. The buffer must not be empty, since RocksDB cannot write an SST file without rows.

impl<K: Serialize, V: Serialize> SstFileBuffer<(u8, K), V>

pub fn insert_tagged( &mut self, map: &TaggedDBMap<K, V>, key: &K, value: &V, ) -> Result<(), TypedStoreError>

Adds a row of map, keyed as map keys its rows, for a file ingested into map’s column family.

Trait Implementations

impl<K: Serialize, V: Serialize> Default for SstFileBuffer<K, V>

fn default() -> Self

Returns the “default value” for a type.