org.apache.flink.table.api

Class SlideWithSizeAndSlide

java.lang.Object

org.apache.flink.table.api.SlideWithSizeAndSlide

@PublicEvolving
public final class SlideWithSizeAndSlide
extends Object

Sliding window. The size of the window either as time or row-count interval.

For streaming tables you can specify grouping by a event-time or processing-time attribute.

For batch tables you can specify grouping on a timestamp or long attribute.

Method Summary

Modifier and Type	Method and Description
SlideWithSizeAndSlideOnTime	on(Expression timeField) Specifies the time attribute on which rows are grouped.

Methods inherited from class java.lang.Object

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

Method Detail

on

public SlideWithSizeAndSlideOnTime on(Expression timeField)

Specifies the time attribute on which rows are grouped.

For streaming tables you can specify grouping by a event-time or processing-time attribute.

For batch tables you can specify grouping on a timestamp or long attribute.

Parameters:

timeField - time attribute for streaming and batch tables

Returns:

a tumbling window on event-time