public final class TumblingDurationWindow extends BaseWindowConfig
windowLength
duration.WindowConfig.Type
slideLength, windowLength
Modifier and Type | Method and Description |
---|---|
<T> WindowStrategy<T> |
getWindowStrategy()
Gives the type of windowing.
|
static TumblingDurationWindow |
of(BaseWindowedBolt.Duration windowLength) |
getSlidingLength, getWindowLength, validate
public static TumblingDurationWindow of(BaseWindowedBolt.Duration windowLength)
public <T> WindowStrategy<T> getWindowStrategy()
WindowConfig
Type
values.Copyright © 2023 The Apache Software Foundation. All rights reserved.