UnlimitedWindows (streams 7.5.12-ce API)

java.lang.Object
- org.apache.kafka.streams.kstream.Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
- - org.apache.kafka.streams.kstream.UnlimitedWindows

```
public final class UnlimitedWindows
extends Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
```
The unlimited window specifications used for aggregations.
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.
See Also:
TimeWindows, SessionWindows, JoinWindows, KGroupedStream.windowedBy(Windows), TimestampExtractor

Field Summary
Fields
Modifier and Type Field and Description
long startMs
The start timestamp of the window.

Fields
Modifier and Type	Field and Description
`long`	`startMs` The start timestamp of the window.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
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.

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

- Field Detail
  - startMs
```
public final long startMs
```
    The start timestamp of the window.
- Method Detail
  - of
```
public static UnlimitedWindows of()
```
    Return an unlimited window starting at timestamp zero.
  - startOn
```
public UnlimitedWindows startOn(Instant start)
                         throws IllegalArgumentException
```
    Return a new unlimited window for the specified start timestamp.
    Parameters:
    start - the window start time
    Returns:
    a new unlimited window that starts at start
    Throws:
    IllegalArgumentException - if the start time is negative or can't be represented as long milliseconds
  - windowsFor
```
public Map<Long,org.apache.kafka.streams.kstream.internals.UnlimitedWindow> windowsFor(long timestamp)
```
    Description copied from class: Windows
    Create all windows that contain the provided timestamp, indexed by non-negative window start timestamps.
    Specified by:
    windowsFor in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
    Parameters:
    timestamp - the timestamp window should get created for
    Returns:
    a map of windowStartTimestamp -> Window entries
  - size
```
public long size()
```
    Return the size of the specified windows in milliseconds. As unlimited windows have conceptually infinite size, this methods just returns Long.MAX_VALUE.
    Specified by:
    size in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
    Returns:
    the size of the specified windows which is Long.MAX_VALUE
  - gracePeriodMs
```
public long gracePeriodMs()
```
    Description copied from class: Windows
    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).
    Specified by:
    gracePeriodMs in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    hashCode in class Object
  - toString
```
public String toString()
```
    Overrides:
    toString in class Object

Class UnlimitedWindows

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

startMs

Method Detail

of

startOn

windowsFor

size

gracePeriodMs

equals

hashCode

toString