Struct MutableRun 

pub struct MutableRun { /* private fields */ }

Implementations

impl MutableRun

pub fn new() -> Self

pub fn insert_many(&mut self, rows: Vec<Row>)

Fold drained memtable rows (already ascending by (RowId, Epoch)) into the tier via one bulk merge + re-spread — far cheaper than per-element inserts, which would cluster at the tail on sorted input.

pub fn len(&self) -> usize

Number of stored versions.

pub fn is_empty(&self) -> bool

pub fn approx_bytes(&self) -> u64

Approximate bytes held — the spill-threshold signal.

pub fn get_version( &self, row_id: RowId, snapshot_epoch: Epoch, ) -> Option<(Epoch, Row)>

Newest version of row_id with epoch <= snapshot (including tombstones). Legacy epoch-only entry point; prefer Self::get_version_at when the caller holds a full Snapshot.

pub fn get_version_at( &self, row_id: RowId, snapshot: Snapshot, ) -> Option<(Epoch, Row)>

Newest version of row_id visible under snapshot (including tombstones), using HLC authority when stamps are present (P0.5-T3). Seeks to row_id’s versions via the PMA’s gappy binary search.

pub fn visible_versions(&self, snapshot_epoch: Epoch) -> Vec<Row>

Newest visible version per RowId at snapshot (including tombstones), ascending by RowId. Legacy epoch-only entry point; prefer Self::visible_versions_at.

pub fn visible_versions_at(&self, snapshot: Snapshot) -> Vec<Row>

Newest visible version per RowId under a full Snapshot, including tombstones. HLC-stamped versions use HLC order (P0.5-T3).

pub fn newest_visible_iter<'a>( &'a self, snapshot: &Snapshot, ) -> MutableRunVisibleVersionCursor<'a>

Borrowing ordered iterator over the newest visible version of each RowId under snapshot (including tombstones). Mirrors Self::newest_visible_map but never clones the row bytes — the yielded &Row borrows from the underlying Pmas for the cursor’s lifetime. The cursor dedups to one entry per RowId (the newest visible version), iterating them in ascending RowId order, exactly like draining the Self::newest_visible_map BTreeMap.

pub fn drain_sorted(&mut self) -> Vec<Row>

Drain every version in ascending (RowId, Epoch) order — the order RunWriter::write requires when spilling to an immutable run.

Trait Implementations

impl Clone for MutableRun

fn clone(&self) -> MutableRun

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MutableRun

fn default() -> Self

Returns the “default value” for a type.