org.apache.flink.table.api

Class Slide

java.lang.Object

org.apache.flink.table.api.Slide

@PublicEvolving
public final class Slide
extends Object

Helper class for creating a sliding window. Sliding windows have a fixed size and slide by a specified slide interval. If the slide interval is smaller than the window size, sliding windows are overlapping. Thus, an element can be assigned to multiple windows.

For example, a sliding window of size 15 minutes with 5 minutes sliding interval groups elements of 15 minutes and evaluates every five minutes. Each element is contained in three consecutive window evaluations.

Java Example:

 Slide.over("10.minutes").every("5.minutes").on("rowtime").as("w")
 

Scala Example:

 Slide over 10.minutes every 5.minutes on 'rowtime as 'w
 

Constructor Summary

Constructors

Constructor and Description
Slide()

Method Summary

Modifier and Type	Method and Description
static SlideWithSize	over(Expression size) Creates a sliding window.

Methods inherited from class java.lang.Object

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

Constructor Detail

Slide

public Slide()

Method Detail

over

public static SlideWithSize over(Expression size)

Creates a sliding window. Sliding windows have a fixed size and slide by a specified slide interval. If the slide interval is smaller than the window size, sliding windows are overlapping. Thus, an element can be assigned to multiple windows.

For example, a sliding window of size 15 minutes with 5 minutes sliding interval groups elements of 15 minutes and evaluates every five minutes. Each element is contained in three consecutive

Parameters:

size - the size of the window as time or row-count interval

Returns:

a partially specified sliding window