risingwave_stream::executor::aggregation

Function iter_table_storage

source
pub fn iter_table_storage<S>(
    state_storages: &mut [AggStateStorage<S>],
) -> impl Iterator<Item = &mut StateTable<S>>
where S: StateStore,