Module session_windowed_cogrouped 

SessionWindowedCogroupedStream<K, VOut>: session-windowed KIP-150 cogroup.

CogroupedKStream::windowed_by_session(SessionWindows) builds it. The terminal aggregate_explicit produces a KTable<Windowed<K>, VOut> over a shared session store. Unlike the time-windowed and sliding-windowed variants, the session aggregate needs a merger that combines two sessions when the runtime merges them.

Structs

SessionWindowedCogroupedStream

Handle produced by CogroupedKStream::windowed_by_session. The terminal session-windowed aggregation consumes it.