public class WindowingTumblingPolicy extends WindowingPolicy
Constructor and Description |
---|
WindowingTumblingPolicy(WindowConfig.Count cnt) |
WindowingTumblingPolicy(WindowConfig.Duration dtn) |
Modifier and Type | Method and Description |
---|---|
WindowConfig.Count |
getCount() |
WindowConfig.Duration |
getDuration() |
WindowType |
getWindowType() |
void |
setCount(WindowConfig.Count cnt) |
void |
setDuration(WindowConfig.Duration dtn) |
void |
setWindowType(WindowType winType) |
boolean |
validate() |
java.lang.String |
whyInvalid() |
reset, shutdown, start, track
public WindowingTumblingPolicy(WindowConfig.Count cnt)
public WindowingTumblingPolicy(WindowConfig.Duration dtn)
public WindowType getWindowType()
getWindowType
in class WindowingPolicy
public void setWindowType(WindowType winType)
public WindowConfig.Count getCount()
getCount
in class WindowingPolicy
public void setCount(WindowConfig.Count cnt)
public WindowConfig.Duration getDuration()
getDuration
in class WindowingPolicy
public void setDuration(WindowConfig.Duration dtn)
public boolean validate()
validate
in interface IWindowingPolicy
validate
in class WindowingPolicy
public java.lang.String whyInvalid()
whyInvalid
in interface IWindowingPolicy
whyInvalid
in class WindowingPolicy