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, trackpublic WindowingTumblingPolicy(WindowConfig.Count cnt)
public WindowingTumblingPolicy(WindowConfig.Duration dtn)
public WindowType getWindowType()
getWindowType in class WindowingPolicypublic void setWindowType(WindowType winType)
public WindowConfig.Count getCount()
getCount in class WindowingPolicypublic void setCount(WindowConfig.Count cnt)
public WindowConfig.Duration getDuration()
getDuration in class WindowingPolicypublic void setDuration(WindowConfig.Duration dtn)
public boolean validate()
validate in interface IWindowingPolicyvalidate in class WindowingPolicypublic java.lang.String whyInvalid()
whyInvalid in interface IWindowingPolicywhyInvalid in class WindowingPolicy