Hi Cody, Aggregations are currently not performed by code-generated user functions. This would be a good improvement though. Check the DataSetAggregate class to learn how aggregations are translated into Flink Dataset programs.
Best, Fabian Von: Cody Innowhere
