org.apache.flink.table.api

Interface OverWindowedTable

@PublicEvolving
public interface OverWindowedTable

A table that has been windowed for OverWindows.

Unlike group windows, which are specified in the GROUP BY clause, over windows do not collapse rows. Instead over window aggregates compute an aggregate for each input row over a range of its neighboring rows.

Method Summary

Modifier and Type	Method and Description
Table	select(Expression... fields) Performs a selection operation on a over windowed table.
Table	select(String fields) Deprecated. use select(Expression...)

Method Detail

select

@Deprecated
Table select(String fields)

Deprecated. use select(Expression...)

Performs a selection operation on a over windowed table. Similar to an SQL SELECT statement. The field expressions can contain complex expressions and aggregations.

Example:

 overWindowedTable.select("c, b.count over ow, e.sum over ow")
 

select

Table select(Expression... fields)

Performs a selection operation on a over windowed table. Similar to an SQL SELECT statement. The field expressions can contain complex expressions and aggregations.

Example:

 overWindowedTable.select(
    $("c"),
    $("b").count().over($("ow")),
    $("e").sum().over($("ow"))
 );
 

Scala Example:

 overWindowedTable.select('c, 'b.count over 'ow, 'e.sum over 'ow)