- class MergingWindowAssigner(*args, **kwds)[source]#
A WindowAssigner that can merge windows.
assign_windows(element, timestamp, context)
- param element
The element to which windows should be assigned.
- param env
The StreamExecutionEnvironment used to compile the DataStream job.
A TypeSerializer for serializing windows that are assigned by this WindowAssigner.
True if elements are assigned to windows based on event time, false otherwise.
Determines which windows (if any) should be merged.