org.apache.flink.table.api

Interface AggregatedTable

@PublicEvolving
public interface AggregatedTable

A table that has been performed on the aggregate function.

Method Summary

Modifier and Type	Method and Description
Table	select(Expression... fields) Performs a selection operation after an aggregate operation.
Table	select(String fields) Deprecated. use select(Expression...)

Method Detail

select

@Deprecated
Table select(String fields)

Deprecated. use select(Expression...)

Performs a selection operation after an aggregate operation. The field expressions cannot contain table functions and aggregations.

Example:

 AggregateFunction aggFunc = new MyAggregateFunction();
 tableEnv.registerFunction("aggFunc", aggFunc);
 table.groupBy("key")
   .aggregate("aggFunc(a, b) as (f0, f1, f2)")
   .select("key, f0, f1");
 

select

Table select(Expression... fields)

Performs a selection operation after an aggregate operation. The field expressions cannot contain table functions and aggregations.

Example:

 AggregateFunction aggFunc = new MyAggregateFunction();
 tableEnv.registerFunction("aggFunc", aggFunc);
 table.groupBy($("key"))
   .aggregate(call("aggFunc", $("a"), $("b")).as("f0", "f1", "f2"))
   .select($("key"), $("f0"), $("f1"));
 

Scala Example:

 val aggFunc = new MyAggregateFunction
 table.groupBy($"key")
   .aggregate(aggFunc($"a", $"b") as ("f0", "f1", "f2"))
   .select($"key", $"f0", $"f1")