public class TumblingWindows extends Windows<org.apache.kafka.streams.kstream.internals.TumblingWindow>
Modifier and Type | Field and Description |
---|---|
long |
size |
Modifier and Type | Method and Description |
---|---|
boolean |
equalTo(Windows other) |
static TumblingWindows |
of(java.lang.String name)
Returns a half-interval sliding window definition with the default window size
|
java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.TumblingWindow> |
windowsFor(long timestamp) |
TumblingWindows |
with(long size)
Returns a half-interval sliding window definition with the window size in milliseconds
|
emit, emitEveryMs, maintainMs, name, newName, segments, until
public static TumblingWindows of(java.lang.String name)
public TumblingWindows with(long size)
public java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.TumblingWindow> windowsFor(long timestamp)
windowsFor
in class Windows<org.apache.kafka.streams.kstream.internals.TumblingWindow>