W
- Type of the window instancepublic abstract class Windows<W extends Window>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
name |
int |
segments |
Modifier | Constructor and Description |
---|---|
protected |
Windows(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
Windows |
emit(long duration)
Set the window emit duration in milliseconds of system time
|
long |
emitEveryMs() |
abstract boolean |
equalTo(Windows other) |
long |
maintainMs() |
java.lang.String |
name() |
protected java.lang.String |
newName(java.lang.String prefix) |
protected Windows |
segments(int segments)
Specifies the number of segments to be used for rolling the window store,
this function is not exposed to users but can be called by developers that extend this JoinWindows specs
|
Windows |
until(long duration)
Set the window maintain duration in milliseconds of system time
|
abstract java.util.Map<java.lang.Long,W> |
windowsFor(long timestamp) |
public java.lang.String name()
public Windows emit(long duration)
public Windows until(long duration)
protected Windows segments(int segments)
segments
- public long emitEveryMs()
public long maintainMs()
protected java.lang.String newName(java.lang.String prefix)
public abstract boolean equalTo(Windows other)
public abstract java.util.Map<java.lang.Long,W> windowsFor(long timestamp)