public class SlideWithSize extends Object
param: size the size of the window either as time or row-count interval.
Constructor and Description |
---|
SlideWithSize(Expression size) |
SlideWithSize(String size)
Partially specified sliding window.
|
Modifier and Type | Method and Description |
---|---|
SlideWithSizeAndSlide |
every(Expression slide)
Specifies the window's slide as time or row-count interval.
|
SlideWithSizeAndSlide |
every(String slide)
Specifies the window's slide as time or row-count interval.
|
public SlideWithSize(Expression size)
public SlideWithSize(String size)
size
- the size of the window either as time or row-count interval.public SlideWithSizeAndSlide every(Expression slide)
The slide determines the interval in which windows are started. Hence, sliding windows can overlap if the slide is smaller than the size of the window.
For example, you could have windows of size 15 minutes that slide by 3 minutes. With this 15 minutes worth of elements are grouped every 3 minutes and each row contributes to 5 windows.
slide
- the slide of the window either as time or row-count interval.public SlideWithSizeAndSlide every(String slide)
The slide determines the interval in which windows are started. Hence, sliding windows can overlap if the slide is smaller than the size of the window.
For example, you could have windows of size 15 minutes that slide by 3 minutes. With this 15 minutes worth of elements are grouped every 3 minutes and each row contributes to 5 windows.
slide
- the slide of the window either as time or row-count interval.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.