pyflink.datastream.window.SlidingEventTimeWindows

class SlidingEventTimeWindows(size: int, slide: int, offset: int)

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

For example, in order to window into windows of 1 minute, every 10 seconds:

>>> data_stream.key_by(lambda x: x[0], key_type=Types.STRING()) \
...     .window(SlidingEventTimeWindows.of(Time.minutes(1), Time.seconds(10)))

Methods

assign_windows(element, timestamp, context)
get_default_trigger(env)
get_window_serializer()
is_event_time()
of(size, slide[, offset])	Creates a new SlidingEventTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp and offset.