risingwave_stream::executor::aggregation

Module agg_group

source

Structs§

  • AggGroup manages agg states of all agg calls for one group_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.

Traits§