pyflink.datastream.window.EventTimeSessionWindows

class EventTimeSessionWindows(session_gap: int)

A WindowAssigner that windows elements into sessions based on the timestamp of the elements. Windows cannot overlap.

For example, Set the timestamp of the element to 1 minutes:

>>> data_stream.key_by(lambda x: x[0], key_type=Types.STRING()) \
...     .window(EventTimeSessionWindows.with_gap(Time.minutes(1)))

Methods

assign_windows(element, timestamp, context)
get_default_trigger(env)
get_window_serializer()
is_event_time()
merge_windows(windows, callback)	Determines which windows (if any) should be merged.
with_dynamic_gap(extractor)	Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.
with_gap(size)	Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.