Struct VersionedKeyState 

pub struct VersionedKeyState {
    pub versions: BTreeMap<i64, SmallVec<[TableRow; 1]>>,
    pub min_version: i64,
    pub max_version: i64,
}

Per-key versioned table state.

Fields

versions: BTreeMap<i64, SmallVec<[TableRow; 1]>>

Rows indexed by version timestamp. Multiple rows at the same timestamp stored in a vector.

min_version: i64

Minimum version timestamp.

max_version: i64

Maximum version timestamp.

Implementations

impl VersionedKeyState

pub fn new() -> Self

Creates a new empty key state.

pub fn insert(&mut self, row: TableRow)

Inserts a table row.

pub fn len(&self) -> usize

Returns the number of rows in this key’s state.

pub fn is_empty(&self) -> bool

Returns true if this key has no rows.

pub fn lookup_at_time(&self, timestamp: i64) -> Option<&TableRow>

Finds the row valid at the given timestamp. Returns the row with the largest version_ts <= event_ts.

pub fn lookup_latest(&self) -> Option<&TableRow>

Finds the latest row (for process-time lookups).

pub fn cleanup_before(&mut self, threshold: i64)

Removes versions before the given timestamp.

pub fn remove_version( &mut self, version: i64, ) -> Option<SmallVec<[TableRow; 1]>>

Removes a specific version (for non-append-only table deletes).

pub fn limit_versions(&mut self, max_versions: usize)

Limits the number of versions (keeps most recent).

Trait Implementations

impl Clone for VersionedKeyState

fn clone(&self) -> VersionedKeyState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for VersionedKeyState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for VersionedKeyState

fn default() -> VersionedKeyState

Returns the “default value” for a type.