pyflink.datastream.window.GlobalWindows#
- class GlobalWindows[source]#
A WindowAssigner that assigns all elements to the same GlobalWindow.
Methods
assign_windows
(element, timestamp, context)- param element
The element to which windows should be assigned.
create
()Creates a new GlobalWindows WindowAssigner that assigns all elements to the same GlobalWindow.
get_default_trigger
(env)- param env
The StreamExecutionEnvironment used to compile the DataStream job.
get_window_serializer
()- return
A TypeSerializer for serializing windows that are assigned by this WindowAssigner.
is_event_time
()- return
True if elements are assigned to windows based on event time, false otherwise.