org.apache.flink.table.api

Class SlideWithSize

java.lang.Object

org.apache.flink.table.api.SlideWithSize

@PublicEvolving
public final class SlideWithSize
extends Object

Partially specified sliding window. The size of the window either as time or row-count interval.

Method Summary

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) Deprecated. use every(Expression)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

every

@Deprecated
public SlideWithSizeAndSlide every(String slide)

Deprecated. use every(Expression)

Specifies the window's slide as time or row-count interval.

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.

Parameters:

slide - the slide of the window either as time or row-count interval.

Returns:

a sliding window

every

public SlideWithSizeAndSlide every(Expression slide)

Specifies the window's slide as time or row-count interval.

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.

Parameters:

slide - the slide of the window either as time or row-count interval.

Returns:

a sliding window