public class UnlimitedWindows extends Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>
Modifier and Type | Field and Description |
---|---|
long |
start |
Modifier and Type | Method and Description |
---|---|
boolean |
equalTo(Windows other) |
static UnlimitedWindows |
of(java.lang.String name)
Returns an unlimited window definition
|
UnlimitedWindows |
startOn(long start) |
java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.UnlimitedWindow> |
windowsFor(long timestamp) |
emit, emitEveryMs, maintainMs, name, newName, segments, until
public static UnlimitedWindows of(java.lang.String name)
public UnlimitedWindows startOn(long start)
public java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.UnlimitedWindow> windowsFor(long timestamp)
windowsFor
in class Windows<org.apache.kafka.streams.kstream.internals.UnlimitedWindow>