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("someUDAF", $("a")).as("res"))
.select(...);
Above works fine for one aggregation per window/group; However I can not
find a way to do multiple aggregations on such a group using the table API.
WindowGroupedTable class has no method as aggregate(Expression...
aggregateFunction) which can take multiple aggregates.
Any suggestions on how multiple aggregations, with UDAFs, could be done via
table API?
