risingwave_stream::executor::aggregate

Module simple_agg

Source

Structs§

ExecutionVars 🔒
ExecutorInner 🔒
SimpleAggExecutor
SimpleAggExecutor is the aggregation operator for streaming system. To create an aggregation operator, states and expressions should be passed along the constructor.