pyflink.datastream.window.GlobalWindows

class GlobalWindows

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.