org.apache.kafka.streams.kstream

Class UnlimitedWindows

java.lang.Object

org.apache.kafka.streams.kstream.Windows<UnlimitedWindow>

org.apache.kafka.streams.kstream.UnlimitedWindows

public class UnlimitedWindows
extends Windows<UnlimitedWindow>

The unlimited window specifications.

Field Summary

Fields

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

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

segments

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
static UnlimitedWindows	of() Return an unlimited window starting at timestamp zero.
long	size()
UnlimitedWindows	startOn(long start) Return a new unlimited window for the specified start timestamp.
Map<Long,UnlimitedWindow>	windowsFor(long timestamp) Creates all windows that contain the provided timestamp, indexed by non-negative window start timestamps.

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

maintainMs, segments, until

Methods inherited from class java.lang.Object

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

Field Detail

start

public final long start

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(long start)

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

windowsFor

public Map<Long,UnlimitedWindow> windowsFor(long timestamp)

Description copied from class: Windows

Creates all windows that contain the provided timestamp, indexed by non-negative window start timestamps.

Specified by:

windowsFor in class Windows<UnlimitedWindow>

Parameters:

timestamp - the timestamp window should get created for

Returns:

a map of windowStartTimestamp -> Window entries

size

public long size()

Specified by:

size in class Windows<UnlimitedWindow>

equals

public final boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object