public final class SlidingDurationWindow extends BaseWindowConfig
Represents configuration of sliding window based on duration. Window duration of windowLength
slides at every slideLength
interval.
WindowConfig.Type
slideLength, windowLength
Modifier and Type | Method and Description |
---|---|
<T> WindowStrategy<T> |
getWindowStrategy()
Gives the type of windowing.
|
static SlidingDurationWindow |
of(BaseWindowedBolt.Duration windowDuration,
BaseWindowedBolt.Duration slidingDuration) |
getSlidingLength, getWindowLength, validate
public static SlidingDurationWindow of(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingDuration)
public <T> WindowStrategy<T> getWindowStrategy()
WindowConfig
Gives the type of windowing. It can be any of Type
values.
Copyright © 2022 The Apache Software Foundation. All rights reserved.