org.apache.storm.trident.windowing.config

Class SlidingDurationWindow

java.lang.Object

org.apache.storm.trident.windowing.config.BaseWindowConfig

org.apache.storm.trident.windowing.config.SlidingDurationWindow

All Implemented Interfaces:

Serializable, WindowConfig

public final class SlidingDurationWindow
extends BaseWindowConfig

Represents configuration of sliding window based on duration. Window duration of windowLength slides at every slideLength interval.

See Also:

Serialized Form

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 Type	Method and Description
<T> WindowStrategy<T>	getWindowStrategy() 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

of

public static SlidingDurationWindow of(BaseWindowedBolt.Duration windowDuration,
                                       BaseWindowedBolt.Duration slidingDuration)

getWindowStrategy

public <T> WindowStrategy<T> getWindowStrategy()

Description copied from interface: WindowConfig

Gives the type of windowing. It can be any of Type values.