Class 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 Details

    • startMs

      public final long startMs
      The start timestamp of the window.
  • Method Details

    • 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.
      start - the window start time
      a new unlimited window that starts at start
      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>
      timestamp - the timestamp window should get created for
      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>
      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)
      equals in class Object
    • hashCode

      public int hashCode()
      hashCode in class Object
    • toString

      public String toString()
      toString in class Object