Package org.apache.kafka.streams.kstream.internals

Class UnlimitedWindow

java.lang.Object

org.apache.kafka.streams.kstream.Window

org.apache.kafka.streams.kstream.internals.UnlimitedWindow

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.

See Also:

TimeWindow, SessionWindow, UnlimitedWindows, TimestampExtractor

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Window

endMs, startMs

Constructor Summary

Constructors

Constructor	Description
UnlimitedWindow(long startMs)	Create a new window for the given start time (inclusive).

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.kafka.streams.kstream.Window

end, endTime, equals, hashCode, start, startTime, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

UnlimitedWindow

public UnlimitedWindow(long startMs)

Create a new window for the given start time (inclusive).

Parameters:

startMs - the start timestamp of the window (inclusive)

Throws:

IllegalArgumentException - if start is negative

Method Detail

overlap

public 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.

Specified by:

overlap in class Window

Parameters:

other - another window

Returns:

true

Throws:

IllegalArgumentException - if the other window has a different type than this window