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

getWindowStrategy

public <T> WindowStrategy<T> getWindowStrategy()

Description copied from interface: WindowConfig

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

Returns:

of

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