Hi!
You can directly use .select() to call an aggregate function (either
built-in or user-defined). See [1] for an example on how to use call()
expression to call an user-defined aggregate function.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/#aggregate-
I am using the Table api in Java to write queries with
grouping/aggregation.
The aggregations may use built-in functions or user defined aggregate
functions. Therefore I am using the aggregate() method on a
WindowGroupedTable.
table.window(...)
.groupBy(...)
.aggregate(Expressions.call("
