@InterfaceStability.Unstable public class UnlimitedWindow extends Window
UnlimitedWindow
is an "infinite" large window with a fixed (inclusive) start time.
All windows of the same window specification
will have the
same start time.
To make the window size "infinite" end time is set to Long.MAX_VALUE
.
For time semantics, see TimestampExtractor
.
TimeWindow
,
SessionWindow
,
UnlimitedWindows
,
TimestampExtractor
Constructor and Description |
---|
UnlimitedWindow(long startMs)
Create a new window for the given start time (inclusive).
|
Modifier and Type | Method and Description |
---|---|
boolean |
overlap(Window other)
Returns
true if the given window is of the same type, because all unlimited windows overlap with each
other due to their infinite size. |
public UnlimitedWindow(long startMs)
startMs
- the start timestamp of the window (inclusive)java.lang.IllegalArgumentException
- if start
is negativepublic boolean overlap(Window other)
true
if the given window is of the same type, because all unlimited windows overlap with each
other due to their infinite size.