public class HoppingWindows extends Windows<org.apache.kafka.streams.kstream.internals.HoppingWindow>
Modifier and Type | Method and Description |
---|---|
boolean |
equalTo(Windows other) |
HoppingWindows |
every(long period)
Returns a new hopping window definition with the original size but reassign the window
period in milliseconds of the form [ N * period, N * period + size )
|
static HoppingWindows |
of(java.lang.String name)
Returns a half-interval hopping window definition with the window size in milliseconds
of the form [ N * default_size, N * default_size + default_size )
|
java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.HoppingWindow> |
windowsFor(long timestamp) |
HoppingWindows |
with(long size)
Returns a new hopping window definition with the original size but reassign the window
period in milliseconds of the form [ N * period, N * period + size )
|
emit, emitEveryMs, maintainMs, name, newName, segments, until
public static HoppingWindows of(java.lang.String name)
public HoppingWindows with(long size)
public HoppingWindows every(long period)
public java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.HoppingWindow> windowsFor(long timestamp)
windowsFor
in class Windows<org.apache.kafka.streams.kstream.internals.HoppingWindow>