public class WindowParameter
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
WindowParameter() |
Modifier and Type | Method and Description |
---|---|
WindowConfig.Duration |
getSldingDurationSize() |
WindowConfig.Count |
getSlidingCountSize() |
WindowConfig.Count |
getWindowCountSize() |
WindowConfig.Duration |
getWindowDurationSize() |
WindowParameter |
withSlidingDurationWindow(long winLength,
java.util.concurrent.TimeUnit winLengthTU,
long slidingLength,
java.util.concurrent.TimeUnit slidingLengthTU) |
WindowParameter |
withSlidingingCountWindow(long winLength,
long slidingLength)
Sliding
|
WindowParameter |
withTumblingCountWindow(long winLength)
Tumbling
|
WindowParameter |
withTumblingDurationWindow(long winLength,
java.util.concurrent.TimeUnit timeUnit) |
public WindowParameter withTumblingCountWindow(long winLength)
public WindowParameter withTumblingDurationWindow(long winLength, java.util.concurrent.TimeUnit timeUnit)
public WindowParameter withSlidingingCountWindow(long winLength, long slidingLength)
public WindowParameter withSlidingDurationWindow(long winLength, java.util.concurrent.TimeUnit winLengthTU, long slidingLength, java.util.concurrent.TimeUnit slidingLengthTU)
public WindowConfig.Count getWindowCountSize()
public WindowConfig.Count getSlidingCountSize()
public WindowConfig.Duration getWindowDurationSize()
public WindowConfig.Duration getSldingDurationSize()