risingwave_stream::executor

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.