Module sliding_windowed_cogrouped 

SlidingWindowedCogroupedStream<K, VOut>: sliding-windowed KIP-150 cogroup.

CogroupedKStream::windowed_by_sliding(SlidingWindows) builds it. The terminal aggregate_explicit produces a KTable<Windowed<K>, VOut> over a shared window store. That store uses the KIP-450 2 * timeDifferenceMs retention formula.

Structs

SlidingWindowedCogroupedStream

Handle produced by CogroupedKStream::windowed_by_sliding. The terminal sliding-windowed aggregation consumes it.