risingwave_stream::executor

Module aggregation

source

Modules§

Structs§

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.

Traits§

Functions§