Class SlidingDurationWindow
java.lang.Object
org.apache.storm.trident.windowing.config.BaseWindowConfig
org.apache.storm.trident.windowing.config.SlidingDurationWindow
- All Implemented Interfaces:
Serializable
,WindowConfig
Represents configuration of sliding window based on duration. Window duration of
windowLength
slides at every slideLength
interval.- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.storm.trident.windowing.config.WindowConfig
WindowConfig.Type
-
Field Summary
Fields inherited from class org.apache.storm.trident.windowing.config.BaseWindowConfig
slideLength, windowLength
-
Method Summary
Modifier and TypeMethodDescription<T> WindowStrategy<T>
Gives the type of windowing.static SlidingDurationWindow
of
(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration) Methods inherited from class org.apache.storm.trident.windowing.config.BaseWindowConfig
getSlidingLength, getWindowLength, validate
-
Method Details
-
of
public static SlidingDurationWindow of(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration) -
getWindowStrategy
Description copied from interface:WindowConfig
Gives the type of windowing. It can be any ofType
values.
-