public final class UnlimitedWindows extends Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
An unlimited time window is also called landmark window. It has a fixed starting point while its window end is defined as infinite. With this regard, it is a fixed-size window with infinite window size.
For time semantics, see TimestampExtractor
.
Modifier and Type | Field and Description |
---|---|
long |
startMs
The start timestamp of the window.
|
DEPRECATED_DEFAULT_24_HR_GRACE_PERIOD, NO_GRACE_PERIOD
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
gracePeriodMs()
Return the window grace period (the time to admit
out-of-order events after the end of the window.)
Delay is defined as (stream_time - record_timestamp).
|
int |
hashCode() |
static UnlimitedWindows |
of()
Return an unlimited window starting at timestamp zero.
|
long |
size()
Return the size of the specified windows in milliseconds.
|
UnlimitedWindows |
startOn(Instant start)
Return a new unlimited window for the specified start timestamp.
|
String |
toString() |
Map<Long,org.apache.kafka.streams.kstream.internals.UnlimitedWindow> |
windowsFor(long timestamp)
Create all windows that contain the provided timestamp, indexed by non-negative window start timestamps.
|
public static UnlimitedWindows of()
public UnlimitedWindows startOn(Instant start) throws IllegalArgumentException
start
- the window start timestart
IllegalArgumentException
- if the start time is negative or can't be represented as long milliseconds
public Map<Long,org.apache.kafka.streams.kstream.internals.UnlimitedWindow> windowsFor(long timestamp)
Windows
windowsFor
in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
timestamp
- the timestamp window should get created forwindowStartTimestamp -> Window
entriespublic long size()
Long.MAX_VALUE
.size
in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
Long.MAX_VALUE
public long gracePeriodMs()
Windows
gracePeriodMs
in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>