Struct KeyState 

pub struct KeyState {
    pub events: BTreeMap<i64, SmallVec<[AsofRow; 1]>>,
    pub min_timestamp: i64,
    pub max_timestamp: i64,
}

Per-key state for ASOF joining.

Uses BTreeMap for O(log n) range queries on timestamps.

Fields

events: BTreeMap<i64, SmallVec<[AsofRow; 1]>>

Events indexed by timestamp for efficient range queries. Multiple events at the same timestamp are stored in a vector.

min_timestamp: i64

Minimum timestamp in this key’s state.

max_timestamp: i64

Maximum timestamp in this key’s state.

Implementations

impl KeyState

pub fn new() -> Self

Creates a new empty key state.

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

Inserts an event into the state.

pub fn len(&self) -> usize

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

pub fn is_empty(&self) -> bool

Returns true if this key has no events.

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

Removes events with timestamps before the given threshold.

Trait Implementations

impl Clone for KeyState

fn clone(&self) -> KeyState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KeyState

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

Formats the value using the given formatter.

impl Default for KeyState

fn default() -> KeyState

Returns the “default value” for a type.