org.apache.kafka.streams.kstream

Class UnlimitedWindows

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 inherited from class org.apache.kafka.streams.kstream.Windows

segments

Method Summary

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()
long	maintainMs() Deprecated. since 2.1. Use Materialized.retention instead.
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.
UnlimitedWindows	startOn(long startMs) Deprecated. Use startOn(Instant) instead
String	toString()
UnlimitedWindows	until(long durationMs) Deprecated. since 2.1.
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 org.apache.kafka.streams.kstream.Windows

segments

Methods inherited from class java.lang.Object

clone, finalize, 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

@Deprecated
public UnlimitedWindows startOn(long startMs)
                                     throws IllegalArgumentException

Deprecated. Use startOn(Instant) instead

Return a new unlimited window for the specified start timestamp.

Parameters:

startMs - the window start time

Returns:

a new unlimited window that starts at startMs

Throws:

IllegalArgumentException - if the start time is negative

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

until

@Deprecated
public UnlimitedWindows until(long durationMs)

Deprecated. since 2.1.

Throws an IllegalArgumentException because the retention time for unlimited windows is always infinite and cannot be changed.

Overrides:

until in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>

Parameters:

durationMs - the window retention time in milliseconds

Returns:

itself

Throws:

IllegalArgumentException - on every invocation.

maintainMs

@Deprecated
public long maintainMs()

Deprecated. since 2.1. Use Materialized.retention instead.

Return the window maintain duration (retention time) in milliseconds. The retention time for unlimited windows in infinite and thus represented as Long.MAX_VALUE.

Overrides:

maintainMs in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>

Returns:

the window retention time that 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