pyflink.datastream.window.TimeWindow

class TimeWindow(start: int, end: int)

Window that represents a time interval from start (inclusive) to end (exclusive).

Methods

cover(other)	Returns the minimal window covers both this window and the given window.
get_window_start_with_offset(timestamp, ...)	Method to get the window start for a timestamp.
intersects(other)	Returns True if this window intersects the given window.
max_timestamp()
merge_windows(windows, callback)	Merge overlapping :class`TimeWindow`.