Struct AsOfJoinCacheEntry 

pub struct AsOfJoinCacheEntry<V: EstimateSize + Clone> {
    inner: BTreeMap<Vec<u8>, JoinRowSet<Vec<u8>, V>>,
    kv_heap_size: KvSize,
}

A cache entry for a single join key, storing all encoded rows indexed by (inequality_key, pk_suffix). The outer BTreeMap gives efficient range queries on inequality keys; the inner JoinRowSet adaptively uses Vec for small pk sets and BTreeMap for larger ones.

V is the encoded row type: OwnedRow for CPU encoding, CompactedRow for memory encoding.

Fields

inner: BTreeMap<Vec<u8>, JoinRowSet<Vec<u8>, V>>

inequality_key_bytes -> { pk_suffix_bytes -> encoded_row }

kv_heap_size: KvSize

Incrementally tracked heap size of all keys and values.

Implementations

impl<V: EstimateSize + Clone> AsOfJoinCacheEntry<V>

fn upper_bound(&self, bound: Bound<&[u8]>) -> Option<&V>

Find the encoded row with the greatest inequality key <= bound (upper bound query). Returns the first entry by pk order in the pk sub-map for that inequality key.

fn lower_bound(&self, bound: Bound<&[u8]>) -> Option<&V>

Find the encoded row with the smallest inequality key >= bound (lower bound query). Returns the first entry by pk order in the pk sub-map for that inequality key.

fn range( &self, range: (Bound<&[u8]>, Bound<&[u8]>), ) -> impl Iterator<Item = &V> + '_ + use<'_, V>

Iterate all encoded rows within an inequality key range.

fn first_by_inequality(&self, ineq_key_bytes: &[u8]) -> Option<&V>

Find the first encoded row (by pk order) with exact inequality key match.

fn first_two_by_inequality( &self, ineq_key_bytes: &[u8], ) -> (Option<&V>, Option<&V>)

Find the first two encoded rows (by PK order) with exact inequality key match.

fn insert( &mut self, ineq_key_bytes: Vec<u8>, pk_suffix_bytes: Vec<u8>, val: V, ) -> Result<(), JoinEntryError>

Insert an encoded row into the cache entry.

fn delete( &mut self, ineq_key_bytes: &Vec<u8>, pk_suffix_bytes: &Vec<u8>, ) -> Result<(), JoinEntryError>

Delete an encoded row from the cache entry.

Trait Implementations

impl<V: EstimateSize + Clone> Default for AsOfJoinCacheEntry<V>

fn default() -> Self

Returns the “default value” for a type.

impl<V: EstimateSize + Clone> EstimateSize for AsOfJoinCacheEntry<V>

fn estimated_heap_size(&self) -> usize

The estimated heap size of the current struct in bytes.

fn estimated_size(&self) -> usize

where Self: Sized,

The estimated total size of the current struct in bytes, including the estimated_heap_size and the size of Self.