pyflink.datastream.window.CountSlidingWindowAssigner

class CountSlidingWindowAssigner(window_size: int, window_slide: int)

A WindowAssigner that windows elements into sliding windows based on the count number of the elements. Windows can possibly overlap.

Methods

assign_windows(element, timestamp, context)
get_default_trigger(env)
get_window_serializer()
is_event_time()
of(window_size, window_slide)