risingwave_stream::executor::aggregate

Module agg_state_cache

Source
Expand description

Object-safe version of StateCache for aggregation.

Structs§

CacheValue
GenericAggStateCache
A wrapper over generic StateCache that implements AggStateCache.
GenericAggStateCacheFiller

Traits§

AggStateCache
Trait that defines the interface of state table cache for stateful streaming agg.
AggStateCacheFiller
Trait that defines agg state cache syncing interface.

Type Aliases§

CacheKey 🔒
Cache key type.