Modules§
- Object-safe version of
StateCache
for aggregation. - distinct 🔒
- minput 🔒
Structs§
AggGroup
manages agg states of all agg calls for onegroup_key
.- Stats for agg state cache operations.
- The strategy that always outputs the aggregation result no matter there’re input rows or not.
GroupKey
wraps a concrete group key and handle its mapping to state table pk.- The strategy that only outputs the aggregation result when there’re input rows. If row count drops to 0, the output row will be deleted.
Enums§
- State for single aggregation call. It manages the state cache and interact with the underlying state store if necessary.
- Represents the persistent storage of aggregation state.