Struct GenericAggStateCache

pub struct GenericAggStateCache<C>
where
    C: StateCache<Key = MemcmpEncoded, Value = CacheValue>,
{
    state_cache: C,
    input_types: Vec<DataType>,
}

A wrapper over generic StateCache that implements AggStateCache.

Fields

state_cache: C

input_types: Vec<DataType>

Implementations

impl<C> GenericAggStateCache<C>

where C: StateCache<Key = MemcmpEncoded, Value = CacheValue>,

pub fn new(state_cache: C, input_types: &[DataType]) -> Self

Trait Implementations

impl<C> AggStateCache for GenericAggStateCache<C>

where C: StateCache<Key = MemcmpEncoded, Value = CacheValue>, for<'a> C::Filler<'a>: Send + Sync,

fn is_synced(&self) -> bool

Check if the cache is synced with state table.

fn apply_batch( &mut self, chunk: &StreamChunk, cache_key_serializer: &OrderedRowSerde, arg_col_indices: &[usize], order_col_indices: &[usize], )

Apply a batch of updates to the cache.

fn begin_syncing(&mut self) -> Box<dyn AggStateCacheFiller + Send + Sync + '_>

Begin syncing the cache with state table.

fn output_batches( &self, chunk_size: usize, ) -> Box<dyn Iterator<Item = StreamChunk> + '_>

Output batches from the cache.

fn output_first(&self) -> Datum

Output the first value.

impl<C> EstimateSize for GenericAggStateCache<C>

where C: StateCache<Key = MemcmpEncoded, Value = CacheValue>,

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.