Struct StreamingSstWriter 

pub struct StreamingSstWriter<E: Entry> { /* private fields */ }

A streaming SST file writer that writes blocks to disk incrementally.

Instead of materializing all entries in memory and then writing all value blocks followed by all key blocks, this writer interleaves block writes as entries arrive. Medium values are written immediately, small values are accumulated into blocks, and key blocks are flushed as soon as their value references are all resolved.

The SST reader is block-index-addressed (not file-position-addressed), so interleaving block types is fully compatible.

Implementations

impl<E: Entry> StreamingSstWriter<E>

pub fn new( file: &Path, flags: MetaEntryFlags, max_entry_count: u64, ) -> Result<Self>

Creates a new streaming SST writer.

max_entry_count is used to size the AMQF filter. It must be an upper bound on the number of entries that will be added; the filter is not resizable. A slightly oversized value only improves the false-positive rate.

pub fn is_full(&self, max_entries: usize, max_data_size: usize) -> bool

Returns true if the SST file has reached capacity limits.

This is intended for compaction callers that need to split output across multiple SST files.

pub fn add(&mut self, entry: E) -> Result<()>

Adds an entry to the SST file. Entries must be added in (key-hash, key) order.

pub fn close(self) -> Result<(StaticSortedFileBuilderMeta<'static>, File)>

Finishes writing the SST file. Flushes remaining blocks, writes the index, and returns metadata.

Trait Implementations

impl<E: Entry> Drop for StreamingSstWriter<E>

Available on debug-assertions enabled only.

fn drop(&mut self)

Executes the destructor for this type.