risingwave_stream::executor::over_window::over_partition

Function shrink_partition_cache

source 
pub(super) fn shrink_partition_cache(
    deduped_part_key: &OwnedRow,
    range_cache: &mut EstimatedBTreeMap<Sentinelled<StateKey>, OwnedRow>,
    cache_policy: OverWindowCachePolicy,
    recently_accessed_range: RangeInclusive<StateKey>,
)