Module session_windowed_kgrouped 

SessionWindowedKGroupedStream<K,V>: the handle between KGroupedStream::windowed_by_session(SessionWindows) and a terminal session aggregation (count/reduce/aggregate).

This type is the session analogue of crate::dsl::windowed_kgrouped::TimeWindowedKGroupedStream. It holds the same grouped lineage plus the SessionWindows spec. Its terminal ops emit Windowed<K> keys and materialize a session store with add_session_store. The result is a KTable<Windowed<K>, _> with a changelog-backed session store.

Structs

SessionWindowedKGroupedStream

Handle produced by KGroupedStream::windowed_by_session.