pyflink.datastream.window.MergingWindowAssigner

class MergingWindowAssigner

A WindowAssigner that can merge windows.

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.