org.apache.storm.trident.windowing.config

Class TumblingDurationWindow

java.lang.Object

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

org.apache.storm.trident.windowing.config.TumblingDurationWindow

All Implemented Interfaces:

Serializable, WindowConfig

public final class TumblingDurationWindow
extends BaseWindowConfig

Represents tumbling duration window configuration. Window tumbles every given windowLength duration.

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 TumblingDurationWindow	of(BaseWindowedBolt.Duration windowLength)

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 TumblingDurationWindow of(BaseWindowedBolt.Duration windowLength)