pyflink.datastream.window.GlobalWindows#
- class GlobalWindows[source]#
A WindowAssigner that assigns all elements to the same GlobalWindow.
Methods
assign_windows(element, timestamp, context)create()Creates a new GlobalWindows WindowAssigner that assigns all elements to the same GlobalWindow.
get_default_trigger(env)get_window_serializer()is_event_time()