Module sliding_windowed_kgrouped 

SlidingWindowedKGroupedStream<K,V>: the handle between KGroupedStream::windowed_by_sliding(SlidingWindows) and a terminal sliding (KIP-450) aggregation.

This type is a sibling of crate::dsl::windowed_kgrouped::TimeWindowedKGroupedStream. It holds the same grouped lineage and window store. Its aggregate processor implements the KIP-450 left-window and right-window algorithm, and its windows are data-defined inclusive windows of size time_difference.

Structs

SlidingWindowedKGroupedStream

Handle that KGroupedStream::windowed_by_sliding produces. Terminal sliding aggregations consume it.