-
Returns a new stream where the values are grouped by keys and the given window.
Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the
reducer.
Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.
Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.
-
class
class
A sliding window specification based on a window length and sliding interval.
class
A tumbling window specification.