org.apache.flink.table.api

Class GroupWindow

java.lang.Object

org.apache.flink.table.api.GroupWindow

Direct Known Subclasses:

SessionWithGapOnTimeWithAlias, SlideWithSizeAndSlideOnTimeWithAlias, TumbleWithSizeOnTimeWithAlias

@PublicEvolving
public abstract class GroupWindow
extends Object

A group window specification.

Group windows group rows based on time or row-count intervals and is therefore essentially a special type of groupBy. Just like groupBy, group windows allow to compute aggregates on groups of elements.

Infinite streaming tables can only be grouped into time or row intervals. Hence window grouping is required to apply aggregations on streaming tables.

For finite batch tables, group windows provide shortcuts for time-based groupBy.

Method Summary

Modifier and Type	Method and Description
Expression	getAlias()
Expression	getTimeField()

Methods inherited from class java.lang.Object

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

Method Detail

getAlias

public Expression getAlias()

getTimeField

public Expression getTimeField()